- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for onStream (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// Use a different task queue for each stream because they should be handled in parallel. taskRunner.newQueue().execute("$connectionName[$streamId] onStream") { try { listener.onStream(newStream) } catch (e: IOException) { Platform.get().log("Http2Connection.Listener failure for $connectionName", INFO, e) ignoreIoExceptions {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
return socket.isHealthy(source) } return true } /** Refuse incoming streams. */ @Throws(IOException::class) override fun onStream(stream: Http2Stream) { stream.close(ErrorCode.REFUSED_STREAM, null) } /** When settings are received, adjust the allocation limit. */ override fun onSettings( connection: Http2Connection,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val maxConcurrentStreamsUpdated = CountDownLatch(1) val maxConcurrentStreams = AtomicInteger() val listener: Http2Connection.Listener = object : Http2Connection.Listener() { override fun onStream(stream: Http2Stream) { throw AssertionError() } override fun onSettings( connection: Http2Connection, settings: Settings, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
internal/grid/grid_test.go
runtime.Gosched() stats := c.Stats() if stats.IncomingStreams != 0 { if i > 0 { time.Sleep(100 * time.Millisecond) continue } var found []uint64 c.inStream.Range(func(key uint64, value *muxServer) bool { found = append(found, key) return true }) t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)