Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 1,021 for streams (0.37 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProjectManager.java

     */
    package org.apache.maven.api.services;
    
    import java.nio.file.Path;
    import java.util.Collection;
    import java.util.List;
    import java.util.Map;
    import java.util.Optional;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.Language;
    import org.apache.maven.api.ProducedArtifact;
    import org.apache.maven.api.Project;
    import org.apache.maven.api.ProjectScope;
    import org.apache.maven.api.RemoteRepository;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Jan 30 23:29:13 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/GAVUtilsTest.java

     */
    package org.apache.maven.cling.invoker.mvnup.goals;
    
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Set;
    import java.util.stream.Stream;
    
    import eu.maveniverse.domtrip.Document;
    import eu.maveniverse.domtrip.maven.Coordinates;
    import org.apache.maven.cling.invoker.mvnup.UpgradeContext;
    import org.junit.jupiter.api.BeforeEach;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Nov 18 18:03:26 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  3. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesJsonFileManager.groovy

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package gradlebuild.binarycompatibility
    
    import com.google.gson.Gson
    import com.google.gson.stream.JsonWriter
    
    class AcceptedApiChangesJsonFileManager {
    
        void emptyAcceptedApiChanges(File jsonFile) {
            jsonFile.withWriter { fileWriter ->
                def writer = new JsonWriter(fileWriter)
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 1K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler.client;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.fess.crawler.entity.RequestData;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultSession.java

        }
    
        @Nonnull
        @Override
        public Collection<ToolchainModel> getToolchains() {
            return getMavenSession().getRequest().getToolchains().values().stream()
                    .flatMap(Collection::stream)
                    .map(org.apache.maven.toolchain.model.ToolchainModel::getDelegate)
                    .toList();
        }
    
        @Nonnull
        @Override
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  6. cmd/untar.go

    	},
    	{
    		// Zstd skippable frame header.
    		header: []byte{0x2a, 0x4d, 0x18},
    		f:      formatZstd,
    	},
    	{
    		// LZ4
    		header: []byte{0x4, 0x22, 0x4d, 0x18},
    		f:      formatLZ4,
    	},
    	{
    		// Snappy/S2 stream
    		header: []byte{0xff, 0x06, 0x00, 0x00},
    		f:      formatS2,
    	},
    	{
    		header: []byte{0x42, 0x5a, 'h'},
    		f:      formatBZ2,
    	},
    }
    
    type untarOptions struct {
    	ignoreDirs bool
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (2)
  7. src/main/java/org/codelibs/fess/app/web/admin/plugin/AdminPluginAction.java

    import java.io.InputStream;
    import java.io.OutputStream;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.io.CopyUtil;
    import org.codelibs.fess.annotation.Secured;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/pac/kerberos/KerberosEncData.java

            ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token));
            ASN1TaggedObject derToken;
            try {
                derToken = ASN1Util.as(ASN1TaggedObject.class, stream);
                if (derToken.getTagClass() != BERTags.APPLICATION) {
                    throw new PACDecodingException("Malformed kerberos ticket");
                }
                stream.close();
            } catch (IOException e) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java

    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.function.Function;
    import java.util.function.Supplier;
    import java.util.stream.Collectors;
    
    import com.google.inject.AbstractModule;
    import com.google.inject.Binder;
    import com.google.inject.name.Names;
    import com.google.inject.spi.ProviderInstanceBinding;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 16:01:38 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt

       * structures.
       *
       * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a
       * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is
       * not terminated.
       *
       * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of
       * the internal list.
       */
      @JvmStatic
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.3K bytes
    - Viewed (0)
Back to top