Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 850 for Stream (0.06 sec)

  1. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

          if (file.isDirectory) {
            serveDirectory(stream, file.listFiles()!!)
          } else if (file.exists()) {
            serveFile(stream, file)
          } else {
            send404(stream, path)
          }
        } catch (e: IOException) {
          Platform.get().log("Failure serving Http2Stream: " + e.message, Platform.INFO, null)
        }
      }
    
      private fun send404(
        stream: Http2Stream,
        path: String,
      ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/ByteSink.java

       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
       * delegate to {@link #openStream()} when the stream returned by that method does not benefit from
       * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new,
       * independent stream each time it is called.
       *
       * <p>The caller is responsible for ensuring that the returned stream is closed.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/ByteSink.java

       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
       * delegate to {@link #openStream()} when the stream returned by that method does not benefit from
       * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new,
       * independent stream each time it is called.
       *
       * <p>The caller is responsible for ensuring that the returned stream is closed.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/util/LogStream.java

         * The current logging level.
         */
        public static int level = 1;
    
        /**
         * Constructs a LogStream with the specified output stream.
         *
         * @param stream the output stream for logging
         */
        public LogStream(final PrintStream stream) {
            super(stream);
        }
    
        /**
         * Sets the logging level.
         *
         * @param level the logging level to set
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

     */
    package org.codelibs.fess.app.service;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.io.IOException;
    import java.io.Reader;
    import java.io.Writer;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/PushObserver.kt

     * correlated by stream ID.
     *
     *  * [onRequest]
     *  * [onHeaders] (unless canceled)
     *  * [onData] (optional sequence of data frames)
     *
     * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple
     * connections should expect repetition of stream IDs.
     *
     * Return true to request cancellation of a pushed stream.  Note that this does not guarantee
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  7. cmd/testdata/decryptObjectInfo.json.zst

    vaLnN88p+j2dWzoEtI1S1Zv84RhCW==","X-Minio-Internal-Server-Side-Encryption-S3-Sealed-Key":"IAAfAPH03fY0cZOkWq9e+Hph0CSZN7kn++8VZP/0w==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/go/testdata/script/build_trimpath.txt","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"xgL1ghXCdZsu25XmeWbg/uPW77dCPfGMygB0Y=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 29 16:34:20 UTC 2020
    - 164K bytes
    - Viewed (0)
  8. api/maven-api-core/src/main/java/org/apache/maven/api/services/LifecycleRegistry.java

    package org.apache.maven.api.services;
    
    import java.util.List;
    import java.util.stream.Stream;
    import java.util.stream.StreamSupport;
    
    import org.apache.maven.api.Lifecycle;
    
    public interface LifecycleRegistry extends ExtensibleEnumRegistry<Lifecycle>, Iterable<Lifecycle> {
    
        default Stream<Lifecycle> stream() {
            return StreamSupport.stream(spliterator(), false);
        }
    
        List<String> computePhases(Lifecycle lifecycle);
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Aug 29 05:48:54 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

         * element count in this stream does not have to be equal.
         */
        @Nonnull
        default Stream<P> problems() {
            Stream<P> result = Stream.empty();
            for (BuilderProblem.Severity severity : BuilderProblem.Severity.values()) {
                result = Stream.concat(result, problems(severity));
            }
            return result;
        }
    
        /**
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/primitives/ImmutableLongArray.java

        }
      }
    
      /**
       * Returns a stream over the values in this array, in order.
       *
       * @since 33.4.0 (but since 22.0 in the JRE flavor)
       */
      // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
      @IgnoreJRERequirement
      public LongStream stream() {
        return Arrays.stream(array, start, end);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 22K bytes
    - Viewed (0)
Back to top