- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for upgradeResponse (0.16 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade_test.go
}, } for i, testCase := range testCases { server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { upgrader := NewResponseUpgrader() conn := upgrader.UpgradeResponse(w, req, nil) haveErr := conn == nil if e, a := testCase.shouldError, haveErr; e != a { t.Fatalf("%d: expected shouldErr=%t, got %t", i, testCase.shouldError, haveErr) } if haveErr { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 20:10:42 UTC 2017 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade.go
return responseUpgrader{pingPeriod: pingPeriod} } // UpgradeResponse upgrades an HTTP response to one that supports multiplexed // streams. newStreamHandler will be called synchronously whenever the // other end of the upgraded connection creates a new stream. func (u responseUpgrader) UpgradeResponse(w http.ResponseWriter, req *http.Request, newStreamHandler httpstream.NewStreamHandler) httpstream.Connection {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:02:09 UTC 2022 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
// add streaming support to them. type ResponseUpgrader interface { // UpgradeResponse upgrades an HTTP response to one that supports multiplexed // streams. newStreamHandler will be called asynchronously whenever the // other end of the upgraded connection creates a new stream. UpgradeResponse(w http.ResponseWriter, req *http.Request, newStreamHandler NewStreamHandler) Connection }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
*/ @Test fun readTimeoutAppliesWithinFrames() { webServer.dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { return upgradeResponse(request) .body(Buffer().write("81".decodeHex())) // Truncated frame. .removeHeader("Content-Length") .socketPolicy(KeepOpen) .build() } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
_, err := httpstream.Handshake(req, w, []string{constants.PortForwardV1Name}) require.NoError(t, err) upgrader := spdy.NewResponseUpgrader() conn := upgrader.UpgradeResponse(w, req, justQueueStream(streamChan)) require.NotNil(t, conn) defer conn.Close() //nolint:errcheck <-stopServerChan })) defer spdyServer.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go
w.WriteHeader(config.statusCode) return } streamCh := make(chan httpstream.Stream) responseUpgrader := NewResponseUpgrader() spdyConn := responseUpgrader.UpgradeResponse(w, req, func(s httpstream.Stream, replySent <-chan struct{}) error { streamCh <- s return nil }) if spdyConn == nil { t.Fatal("unexpected nil spdyConn") } defer spdyConn.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 32.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
if err != nil { return nil, err } upgrader := spdy.NewResponseUpgrader() streamCh := make(chan streamAndReply) conn := upgrader.UpgradeResponse(w, req, func(stream httpstream.Stream, replySent <-chan struct{}) error { streamCh <- streamAndReply{Stream: stream, replySent: replySent} return nil }) ctx := &streamContext{ conn: conn, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
src/net/http/serve_test.go
return } io.WriteString(conn, upgradeResponse) })).ts c, err := net.Dial("tcp", ts.Listener.Addr().String()) if err != nil { t.Fatalf("Dial: %v", err) } defer c.Close() io.WriteString(c, "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n") slurp, err := io.ReadAll(c) if err != nil { t.Fatal(err) } if string(slurp) != upgradeResponse {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0)