Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 882 for Streams (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt

        val bit = 1 shl ENABLE_PUSH
        return if (bit and set != 0) values[ENABLE_PUSH] == 1 else defaultValue
      }
    
      fun getMaxConcurrentStreams(): Int {
        val bit = 1 shl MAX_CONCURRENT_STREAMS
        return if (bit and set != 0) values[MAX_CONCURRENT_STREAMS] else Int.MAX_VALUE
      }
    
      fun getMaxFrameSize(defaultValue: Int): Int {
        val bit = 1 shl MAX_FRAME_SIZE
        return if (bit and set != 0) values[MAX_FRAME_SIZE] else defaultValue
      }
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/SettingsTest.kt

    import assertk.assertions.isTrue
    import org.junit.jupiter.api.Test
    
    class SettingsTest {
      @Test
      fun unsetField() {
        val settings = Settings()
        assertThat(settings.isSet(Settings.MAX_CONCURRENT_STREAMS)).isFalse()
        assertThat(settings.getMaxConcurrentStreams()).isEqualTo(Int.MAX_VALUE)
      }
    
      @Test
      fun setFields() {
        val settings = Settings()
        settings[Settings.HEADER_TABLE_SIZE] = 8096
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  3. 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
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Tue Jan 30 00:14:39 GMT 2024
    - 35.3K bytes
    - Viewed (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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Jan 30 00:14:39 GMT 2024
    - 35.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Ordering.java

     * well.
     *
     * <h3>Java 8+ users</h3>
     *
     * <p>If you are using Java 8+, this class is now obsolete. Most of its functionality is now
     * provided by {@link java.util.stream.Stream Stream} and by {@link Comparator} itself, and the rest
     * can now be found as static methods in our new {@link Comparators} class. See each method below
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 39.4K bytes
    - Viewed (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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 26.2K bytes
    - Viewed (0)
  7. docs/debugging/inspect/decrypt-v2.go

    				}
    				if err := stream.Skip(); err != nil {
    					return fmt.Errorf("stream skip: %w", err)
    				}
    				continue
    			}
    			if extracted {
    				return keepFileErr{fmt.Errorf("next stream: %w", err)}
    			}
    			return fmt.Errorf("next stream: %w", err)
    		}
    		if stream.Name == "inspect.zip" {
    			if extracted {
    				return keepFileErr{errors.New("multiple inspect.zip streams found")}
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  8. 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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 22.4K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    This is necessary for bookkeeping when creating new streams. Correct framing requires that stream IDs are sequential on the socket, so we need to bundle assigning the ID with sending the `SYN_STREAM` frame.
    
    ## Connection Pool
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Iterables.java

       * RandomAccess} support, then this operation is guaranteed to be {@code O(1)}.
       *
       * <p><b>{@code Stream} equivalent:</b> {@link Streams#findLast Streams.findLast(stream).get()}
       *
       * @return the last element of {@code iterable}
       * @throws NoSuchElementException if the iterable is empty
       */
      @ParametricNullness
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 42.5K bytes
    - Viewed (0)
Back to top