- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for jetstream (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
this.type = Http2.TYPE_DATA this.inFinished = inFinished this.streamId = streamId this.data = source.readByteString(length.toLong()).toByteArray() } override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { check(type == -1) this.type = Http2.TYPE_RST_STREAM this.streamId = streamId this.errorCode = errorCode }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/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(
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/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, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} @Throws(IOException::class) fun flush() { this.withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { this.withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) frameHeader(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V HSPLokhttp3/internal/http2/Http2Connection;->getStream(I)Lokhttp3/internal/http2/Http2Stream; HSPLokhttp3/internal/http2/Http2Connection;->pushedStream$okhttp(I)Z HSPLokhttp3/internal/http2/Http2Connection;->removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
// Verify the peer received what was expected. val rstStream = peer.takeFrame() assertThat(rstStream.type).isEqualTo(Http2.TYPE_RST_STREAM) assertThat(rstStream.streamId).isEqualTo(2) assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL) } /**
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) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
override fun writeRequestHeaders(request: Request) { if (stream != null) return val hasRequestBody = request.body != null val requestHeaders = http2HeadersList(request) stream = http2Connection.newStream(requestHeaders, hasRequestBody) // We may have been asked to cancel while creating the new stream and sending the request // headers, but there was still no stream to close. if (canceled) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/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) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0)