- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 790 for stream (0.18 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt
*/ @ExperimentalOkHttpApi interface Stream { val requestBody: BufferedSource val responseBody: BufferedSink /** * Terminate the stream so that no further data is transmitted or received. Note that * [requestBody] may return data after this call; that is the buffered data received before this * stream was canceled. *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.3K bytes - Viewed (0) -
internal/grid/stream.go
// If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/metacache-stream.go
"github.com/tinylib/msgp/msgp" "github.com/valyala/bytebufferpool" ) // metadata stream format: // // The stream is s2 compressed. // https://github.com/klauspost/compress/tree/master/s2#s2-compression // This ensures integrity and reduces the size typically by at least 50%. // // All stream elements are msgpack encoded. // // 1 Integer, metacacheStreamVersion of the writer.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/metacache-stream_test.go
Klaus Post <******@****.***> 1663610716 +0200
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/StreamsTest.java
Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); Stream<String> concatenated = Stream.<Stream<String>>of(Stream.of("a"), streamB, Stream.empty(), Stream.of("c", "d")) .reduce(Stream.empty(), Stream::concat); assertThat(concatenated).containsExactly("a", "b", "c", "d").inOrder(); concatenated.close(); assertThat(closeCountB.get()).isEqualTo(1); }
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 20K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // DATA peer.acceptFrame() // DATA with FLAG_FIN peer.acceptFrame() // RST_STREAM peer.play() // Play it back. val connection = connect(peer) val stream = connection.newStream(headerEntries("a", "android"), true) val source = stream.getSource() val out = stream.getSink().buffer() source.close() assertFailsWith<IOException> {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else { check(isLocallyInitiated) { "remotely-initiated streams should have headers" } } } /** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream.
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.2K bytes - Viewed (1) -
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 Mar 22 12:43:11 GMT 2024 - Last Modified: Tue Jan 30 00:14:39 GMT 2024 - 35.7K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Jun 26 22:36:56 GMT 2023 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MoreCollectors.java
/** * A collector that converts a stream of zero or one elements to an {@code Optional}. * * @throws IllegalArgumentException if the stream consists of two or more elements. * @throws NullPointerException if any element in the stream is {@code null}. * @return {@code Optional.of(onlyElement)} if the stream has exactly one element (must not be
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Fri Dec 08 18:58:42 GMT 2023 - 5.6K bytes - Viewed (0)