Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for newStream (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to Top