- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 882 for Streams (0.81 sec)
-
internal/grid/grid_test.go
start := time.Now() stream, err := handler.Call(context.Background(), remoteConn, &testRequest{Num: 1, String: testPayload}) errFatal(err) go func() { defer close(stream.Requests) for i := 0; i < payloads; i++ { // t.Log("sending new client request") stream.Requests <- &testRequest{Num: i, String: testPayload} } }() var n int err = stream.Results(func(resp *testResponse) error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
* input element is mapped to a key and a stream of values, each of which are put into the * resulting {@code Multimap}, in the encounter order of the stream and the encounter order of the * streams of values. * * <p>Example: * * <pre>{@code * static final ImmutableSetMultimap<Character, Character> FIRST_LETTER_MULTIMAP = * Stream.of("banana", "apple", "carrot", "asparagus", "cherry")
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 23.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
throw IOException("unexpected journal line: $strings") } /** * Returns a snapshot of this entry. This opens all streams eagerly to guarantee that we see a * single published snapshot. If we opened streams lazily then the streams could come from * different edits. */ internal fun snapshot(): Snapshot? { ******@****.***ThreadHoldsLock()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/http2/Http2FlowControlConnectionListener.kt
*/ package okhttp3.internal.http2 import okhttp3.ConnectionListener import okhttp3.internal.http2.flowcontrol.WindowCounter /** * ConnectionListener that outputs CSV for flow control of client receiving streams. */ class Http2FlowControlConnectionListener : ConnectionListener(), FlowControlListener { val start = System.currentTimeMillis() override fun receivingStreamWindowChanged( streamId: Int,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Comparators.java
* * <p>For example: * * <pre>{@code * Stream.of("foo", "quux", "banana", "elephant") * .collect(least(2, comparingInt(String::length))) * // returns {"foo", "quux"} * }</pre> * * <p>This {@code Collector} uses O(k) memory and takes expected time O(n) (worst-case O(n log * k)), as opposed to e.g. {@code Stream.sorted(comparator).limit(k)}, which currently takes O(n
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 11 08:42:51 GMT 2024 - 10K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableBiMap.java
import java.util.Arrays; import java.util.Collection; import java.util.Comparator; import java.util.Map; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collector; import java.util.stream.Collectors; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 08 18:58:42 GMT 2023 - 22K bytes - Viewed (0) -
internal/grid/handlers.go
for req := range reqT { b, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize())) if err != nil { gridLogOnceIf(ctx, err, err.Error()) } h.PutRequest(req) stream.Requests <- b } }() } else if stream.Requests != nil { xioutil.SafeClose(stream.Requests) } return &TypedStream[Req, Resp]{responses: stream, newResp: h.NewResponse, Requests: reqT}, nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
val message = "f248cdc9c957c8cc4bcb492cc9cccf530400".decodeHex() assertThat(inflater.inflate(message)).isEqualTo("Hello inflation!".encodeUtf8()) } /** * We had a bug where self-finishing inflater streams would infinite loop! * https://github.com/square/okhttp/issues/8078 */ @Test fun `inflate returns finished before bytesRead reaches input length`() { val inflater = MessageInflater(false)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 06 05:31:00 GMT 2024 - 5K bytes - Viewed (0) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/apache/maven/wagon/wagon-provider-api/1.0-beta-2/wagon-provider-api-1.0-beta-2.jar
synchronized class CommandExecutionExce extends WagonException { public void CommandExecutionExce(String); public void CommandExecutionExce(String, Throwable); } org/apache/maven/wagon/Streams.class package org.apache.maven.wagon; public synchronized class Streams { private String out; private String err; public void Streams(); public String getOut(); public void setOut(String); public String getErr(); public void setErr(String); } org/apache/maven/wagon/InputData.class package org.apache.maven.wagon;...
Archive - Registered: Sun Mar 31 03:35:09 GMT 2024 - Last Modified: Tue Oct 16 20:15:40 GMT 2007 - 45.2K bytes - Viewed (0) -
internal/grid/connection.go
} // NewStream creates a new stream. // Initial payload can be reused by the caller. func (c *Connection) NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) { if !h.valid() { return nil, ErrUnknownHandler } if c.State() != StateConnected { return nil, ErrDisconnected } handler := c.handlers.streams[h] if handler == nil { return nil, ErrUnknownHandler
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0)