- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for streamChan (0.09 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
"k8s.io/client-go/tools/portforward" ) func TestTunnelingHandler_UpgradeStreamingAndTunneling(t *testing.T) { // Create fake upstream SPDY server, with channel receiving SPDY streams. streamChan := make(chan httpstream.Stream) defer close(streamChan) stopServerChan := make(chan struct{}) defer close(stopServerChan) spdyServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0)