- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewServerConnection (0.34 sec)
-
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) -
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)