- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for newStream (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // DATA STREAM 3 peer.play() // Play it back. val connection = connect(peer) val stream1 = connection.newStream(headerEntries("a", "android"), true) val stream2 = connection.newStream(headerEntries("b", "banana"), true) connection.writePingAndAwaitPong() // Ensure the GO_AWAY that resets stream2 has been received. val sink1 = stream1.sink.buffer()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0) -
internal/grid/grid_test.go
if _, ok := err.(*RemoteErr); !ok { t.Fatalf("Unexpected error: %v, %T", err, err) } // Streams should not be able to set up until registered. // Thus, the error is a local error. _, err = remoteConn.NewStream(t.Context(), handlerTest, []byte(testPayload)) if !errors.Is(err, ErrUnknownHandler) { t.Fatalf("Unexpected error: %v, %T", err, err) } }) } func TestSingleRoundtripGenerics(t *testing.T) {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
internal/grid/README.md
}) ``` Sample call: ```go // Get a connection to the remote host conn := manager.Connection(host).Subroute("asubroute") payload := []byte("request") stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload) if err != nil { return err } // Read results from the stream err = stream.Results(func(result []byte) error {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/grid/connection_test.go
}() <-gotCall remote.debugMsg(debugKillInbound) local.debugMsg(debugKillInbound) <-gotResp // Must reconnect errFatal(remoteConn.WaitForConnect(t.Context())) stream, err := remoteConn.NewStream(t.Context(), handlerTest2, []byte(testPayload)) errFatal(err) go func() { for resp := range stream.responses { t.Log("Resp:", resp, err) } gotResp <- struct{}{} }() <-gotCall
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/grid/connection.go
} client.cancelFn(context.Canceled) c.outgoing.Delete(client.MuxID) }() return client.traceRoundtrip(ctx, c.trace, h, req) } // 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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
cmd/storage-rest-server.go
) var errDiskStale = errors.New("drive stale") // To abstract a disk over network. type storageRESTServer struct { endpoint Endpoint } var ( storageCheckPartsRPC = grid.NewStream[*CheckPartsHandlerParams, grid.NoPayload, *CheckPartsResp](grid.HandlerCheckParts3, func() *CheckPartsHandlerParams { return &CheckPartsHandlerParams{} }, nil, func() *CheckPartsResp { return &CheckPartsResp{} })
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
cmd/peer-rest-client.go
gridConn := client.gridConn() if gridConn == nil { return } payload, err := json.Marshal(traceOpts) if err != nil { bugLogIf(ctx, err) return } st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error { select { case traceCh <- b: default: // Do not block on slow receivers.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0)