Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 780 for upstream (0.04 sec)

  1. 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)
  2. android/guava/src/com/google/common/collect/Iterables.java

       *
       * <p><b>Java 8+ users:</b> If passing a single element {@code e}, the {@code Stream} equivalent
       * of this method is {@code Stream.generate(() -> e)}. Otherwise, put the elements in a collection
       * and use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}.
       */
      @SafeVarargs
      public static <T extends @Nullable Object> Iterable<T> cycle(T... elements) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 43.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/ByteStreams.java

      /**
       * Copies all bytes from the input stream to the output stream. Does not close or flush either
       * stream.
       *
       * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the
       * equivalent {@link InputStream#transferTo} method instead.
       *
       * @param from the input stream to read from
       * @param to the output stream to write to
       * @return the number of bytes copied
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  4. 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)
  5. src/main/java/org/codelibs/fess/app/web/base/login/SamlCredential.java

                    permissionSet.add(systemHelper.getSearchRoleByUser(nameId));
                    stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s))));
                    stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s))));
                    permissions = permissionSet.toArray(new String[permissionSet.size()]);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.4K 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. android/guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.3K bytes
    - Viewed (0)
Back to top