- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for supportsStreamClose (0.24 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
} // handle implements a websocket handler. func (conn *Conn) handle(ws *websocket.Conn) { conn.initialize(ws) defer conn.Close() supportsStreamClose := protocolSupportsStreamClose(conn.selectedProtocol) for { conn.resetTimeout() var data []byte if err := websocket.Message.Receive(ws, &data); err != nil { if err != io.EOF {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0)