- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NoOpNewStreamHandler (0.28 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
// the stream is rejected. After the reply frame has been sent, replySent is closed. type NewStreamHandler func(stream Stream, replySent <-chan struct{}) error // NoOpNewStreamHandler is a stream handler that accepts a new stream and // performs no other logic. func NoOpNewStreamHandler(stream Stream, replySent <-chan struct{}) error { return nil } // Dialer knows how to open a streaming connection to a server. type Dialer interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
spdyConn, err := spdystream.NewConnection(conn, false) if err != nil { defer conn.Close() 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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0)