- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for onStream (0.15 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) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
) as SSLSocket sslSocket.useClientMode = false Platform.get().configureTlsExtensions(sslSocket, null, listOf(Protocol.HTTP_2)) sslSocket.startHandshake() return sslSocket } override fun onStream(stream: Http2Stream) { try { val requestHeaders = stream.takeHeaders() var path: String? = null var i = 0 val size = requestHeaders.size while (i < size) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K 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) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
private val socket: Socket, private val protocol: Protocol, ) : Http2Connection.Listener() { private val sequenceNumber = AtomicInteger() @Throws(IOException::class) override fun onStream(stream: Http2Stream) { val peekedResponse = dispatcher.peek() if (peekedResponse.socketPolicy is ResetStreamAtStart) { dispatchBookkeepingRequest(sequenceNumber.getAndIncrement(), socket)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.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)