Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 953 for streams (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/test/java/jcifs/netbios/NbtExceptionTest.java

    package jcifs.netbios;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.junit.jupiter.api.Assertions.fail;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.Arguments;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/core/io/ResourceTraversalUtil.java

        }
    
        /**
         * Traverses resources contained in a ZIP file input stream.
         * <p>
         * Of the resources in the input stream, only those with paths starting with the specified prefix are traversed.
         * The handler receives the entry name with the prefix removed. For example, if the prefix is <code>/aaa/bbb/</code>
         * and the input stream contains a resource <code>/aaa/bbb/ccc/ddd/eee.txt</code>, the handler receives
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  3. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProject.java

            return Stream.iterate(this.project, Objects::nonNull, MavenProject::getParent)
                    .flatMap(project -> project.getModel().getDelegate().getProfiles().stream())
                    .toList();
        }
    
        @Override
        @Nonnull
        public List<Profile> getDeclaredActiveProfiles() {
            return project.getActiveProfiles().stream()
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Mar 24 22:23:23 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/io/ByteSourceTest.java

       * offset that is greater than the current length of the source, a stream is then opened to that
       * source, and finally additional bytes are appended to the source before the stream is read.
       *
       * <p>Without special handling, it's possible to have reads of the open stream start <i>before</i>
       * the offset at which the slice is supposed to start.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  5. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/ParserRequest.java

        @Nullable
        Path userHome();
    
        /**
         * Returns the input stream to be used for the Maven execution.
         * If not set, {@link System#in} will be used by default.
         *
         * @return the input stream, or null if not set
         */
        @Nullable
        InputStream stdIn();
    
        /**
         * Returns the output stream to be used for the Maven execution.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt

     * body.
     *
     * ### The response body can be consumed only once.
     *
     * This class may be used to stream very large responses. For example, it is possible to use this
     * class to read a response that is larger than the entire memory allocated to the current process.
     * It can even stream a response larger than the total storage on the current device, which is a
     * common requirement for video streaming applications.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:51:25 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/suggest/entity/SuggestItemSerializer.java

    import java.time.Instant;
    import java.time.ZonedDateTime;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Stream;
    
    import org.codelibs.fess.suggest.constants.FieldNames;
    import org.codelibs.fess.suggest.util.SuggestUtil;
    
    /**
     * Utility class for serializing and deserializing SuggestItem objects.
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/core/io/WriterUtil.java

         */
        protected WriterUtil() {
        }
    
        /**
         * Creates a {@link Writer} to output to a stream with the specified encoding.
         *
         * @param os the stream (must not be {@literal null})
         * @param encoding the encoding (must not be {@literal null} or empty)
         * @return a {@link Writer} to output to the stream
         */
        public static Writer create(final OutputStream os, final String encoding) {
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 3K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/artifact/resolver/filter/ExclusionArtifactFilter.java

            this.exclusions = exclusions;
            this.predicates =
                    exclusions.stream().map(ExclusionArtifactFilter::toPredicate).collect(Collectors.toList());
        }
    
        @Override
        public boolean include(Artifact artifact) {
            return predicates.stream().noneMatch(p -> p.test(artifact));
        }
    
        private static Predicate<Artifact> toPredicate(Exclusion exclusion) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  10. src/main/java/jcifs/FileNotifyInformation.java

         */
        int FILE_ACTION_RENAMED_NEW_NAME = 0x00000005;
    
        /**
         * File stream has been added
         */
        int FILE_ACTION_ADDED_STREAM = 0x00000006;
        /**
         * File stream has been removed
         */
        int FILE_ACTION_REMOVED_STREAM = 0x00000007;
        /**
         * File stream has modified
         */
        int FILE_ACTION_MODIFIED_STREAM = 0x00000008;
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
Back to Top