- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 821 for straum (0.2 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 Apr 12 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 Apr 07 19:28:10 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 Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
internal/event/target/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/metacache-stream_test.go
Klaus Post <******@****.***> 1663610716 +0200
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
guava/src/com/google/common/collect/FluentIterable.java
* elements. * * <p><b>{@code Stream} equivalent:</b> if the source iterable has only a single element {@code * e}, use {@code Stream.generate(() -> e)}. Otherwise, collect your stream into a collection and * use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}. */ public final FluentIterable<E> cycle() { return from(Iterables.cycle(getDelegate()));
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) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
Java - Registered: Fri Apr 12 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM on stream 1 for (i in 0 until framesThatFillWindow) { peer.acceptFrame() // DATA on stream 1 } peer.acceptFrame() // SYN_STREAM on stream 2 peer.acceptFrame() // DATA on stream 2 peer.play() // Play it back. val connection = connect(peer) val stream1 = connection.newStream(headerEntries("a", "apple"), true)
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 75.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/collect/StreamsBenchmark.java
@Override Object operate(Stream<?> stream) { return Streams.findLast(stream); } }, REDUCE_LAST { @Override Object operate(Stream<?> stream) { return stream.reduce((a, b) -> b); } }, REDUCE_LAST_PARALLEL { @Override Object operate(Stream<?> stream) { return stream.parallel().reduce((a, b) -> b); } };
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Nov 03 19:39:41 GMT 2016 - 2.8K bytes - Viewed (0)