Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewServerConnection (0.34 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go

    		return nil, err
    	}
    
    	return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
    }
    
    // NewServerConnection creates a new SPDY server connection. newStreamHandler
    // will be invoked when the server receives a newly created stream from the
    // client.
    func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.Connection, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 01 15:04:07 UTC 2021
    - 6.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go

    	if err != nil {
    		t.Errorf("server: error accepting connection: %v", err)
    		return
    	}
    
    	streamChan := make(chan httpstream.Stream)
    	replySentChan := make(chan (<-chan struct{}))
    	spdyConn, err := NewServerConnection(conn, func(stream httpstream.Stream, replySent <-chan struct{}) error {
    		streamChan <- stream
    		replySentChan <- replySent
    		return nil
    	})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 11:58:57 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top