Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 525 for Streams (0.06 seconds)

  1. guava/src/com/google/common/collect/Streams.java

        }
      }
    
      /**
       * Returns a {@link Stream} containing the elements of the first stream, followed by the elements
       * of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/Streams.java

        }
      }
    
      /**
       * Returns a {@link Stream} containing the elements of the first stream, followed by the elements
       * of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

              writeBytesTotal >= writeBytesMaximum ||
              stream.writeBytesTotal >= stream.writeBytesMaximum
            if (stream.isOpen) {
              streams[streamId] = stream
            }
          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/FluentIterable.java

       * iterator supports it.
       *
       * <p><b>{@code Stream} equivalent:</b> to concatenate an arbitrary number of streams, use {@code
       * Stream.of(stream1, stream2, ...).flatMap(s -> s)}. If the sources are iterables, use {@code
       * Stream.of(iter1, iter2, ...).flatMap(Streams::stream)}.
       *
       * @throws NullPointerException if any of the provided iterables is {@code null}
       * @since 20.0
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/FluentIterable.java

       * iterator supports it.
       *
       * <p><b>{@code Stream} equivalent:</b> to concatenate an arbitrary number of streams, use {@code
       * Stream.of(stream1, stream2, ...).flatMap(s -> s)}. If the sources are iterables, use {@code
       * Stream.of(iter1, iter2, ...).flatMap(Streams::stream)}.
       *
       * @throws NullPointerException if any of the provided iterables is {@code null}
       * @since 20.0
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/ByteSource.java

      }
    
      /**
       * Concatenates multiple {@link ByteSource} instances into a single source. Streams returned from
       * the source will contain the concatenated data from the streams of the underlying sources.
       *
       * <p>Only one underlying stream will be open at a time. Closing the concatenated stream will
       * close the open underlying stream.
       *
       * @param sources the sources to concatenate
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Concatenates multiple {@link CharSource} instances into a single source. Streams returned from
       * the source will contain the concatenated data from the streams of the underlying sources.
       *
       * <p>Only one underlying stream will be open at a time. Closing the concatenated stream will
       * close the open underlying stream.
       *
       * @param sources the sources to concatenate
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 25.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/io/MoreFiles.java

        try (DirectoryStream<Path> stream = Files.newDirectoryStream(path)) {
          if (stream instanceof SecureDirectoryStream) {
            SecureDirectoryStream<Path> sds = (SecureDirectoryStream<Path>) stream;
            exceptions = deleteDirectoryContentsSecure(sds);
          } else {
            checkAllowsInsecure(path, options);
            exceptions = deleteDirectoryContentsInsecure(stream);
          }
        } catch (IOException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 16:07:06 GMT 2025
    - 34.6K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

     * layer primitives: connections, requests, responses, and streams.
     *
     * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest
     * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not
     * the other streams sharing its connection. But if the TLS handshake is still in progress then
     * canceling may break the entire connection.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

       * chosen. Guarded by this.
       */
      internal var routeFailureCount = 0
    
      private var successCount = 0
      private var refusedStreamCount = 0
    
      /**
       * The maximum number of concurrent streams that can be carried by this connection. If
       * `allocations.size() < allocationLimit` then new streams can be created on this connection.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
Back to Top