- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for rstStream (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
stream!!.receiveHeaders(headerBlock.toHeaders(), inFinished) } override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { if (pushedStream(streamId)) { pushResetLater(streamId, errorCode) return } val rstStream = removeStream(streamId) rstStream?.receiveRstStream(errorCode) } override fun settings(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
val errorCodeInt = source.readInt() val errorCode = ErrorCode.fromHttp2(errorCodeInt) ?: throw IOException( "TYPE_RST_STREAM unexpected error code: $errorCodeInt", ) handler.rstStream(streamId, errorCode) } @Throws(IOException::class) private fun readSettings( handler: Handler, length: Int, flags: Int, streamId: Int, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 19.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
} } @Throws(IOException::class) fun flush() { withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) frameHeader(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt
frame.writeInt(expectedStreamId and 0x7fffffff) frame.writeInt(ErrorCode.PROTOCOL_ERROR.httpCode) reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { assertThat(streamId).isEqualTo(expectedStreamId) assertThat(errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 28.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
} } fun readTimeout(): Timeout = readTimeout fun writeTimeout(): Timeout = writeTimeout /** * Abnormally terminate this stream. This blocks until the `RST_STREAM` frame has been * transmitted. */ @Throws(IOException::class) fun close( rstStatusCode: ErrorCode, errorException: IOException?, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0)