- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for hocontinuation (0.2 sec)
-
okhttp-coroutines/src/main/kotlin/okhttp3/JvmCallExtensions.kt
suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse( call: Call,
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
const val TYPE_GOAWAY = 0x7 const val TYPE_WINDOW_UPDATE = 0x8 const val TYPE_CONTINUATION = 0x9 const val FLAG_NONE = 0x0 const val FLAG_ACK = 0x1 // Used for settings and ping. const val FLAG_END_STREAM = 0x1 // Used for headers and data. const val FLAG_END_HEADERS = 0x4 // Used for headers and continuation. const val FLAG_END_PUSH_PROMISE = 0x4 const val FLAG_PADDED = 0x8 // Used for headers and data.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
} } if (isFinalFrame) break // We are exhausted and have no continuations. readUntilNonControlFrame() if (opcode != OPCODE_CONTINUATION) { throw ProtocolException("Expected continuation opcode. Got: ${opcode.toHexString()}") } } } @Throws(IOException::class) override fun close() { messageInflater?.close() }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
fun flagOverlapOn0x4() { assertThat(frameLog(true, 3, 10000, TYPE_HEADERS, 0x4)) .isEqualTo("<< 0x00000003 10000 HEADERS END_HEADERS") assertThat(frameLog(true, 3, 10000, TYPE_CONTINUATION, 0x4)) .isEqualTo("<< 0x00000003 10000 CONTINUATION END_HEADERS") assertThat(frameLog(true, 4, 10000, TYPE_PUSH_PROMISE, 0x4)) .isEqualTo("<< 0x00000004 10000 PUSH_PROMISE END_PUSH_PROMISE") } @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
frame.writeInt(expectedStreamId and 0x7fffffff) frame.write(headerBlock, Http2.INITIAL_MAX_FRAME_SIZE.toLong()) // Write the continuation frame, specifying no more frames are expected. writeMedium(frame, headerBlock.size.toInt()) frame.writeByte(Http2.TYPE_CONTINUATION) frame.writeByte(FLAG_END_HEADERS) frame.writeInt(expectedStreamId and 0x7fffffff) frame.writeAll(headerBlock)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
okhttp-coroutines/api/okhttp-coroutines.api
public final class okhttp3/coroutines/ExecuteAsyncKt { public static final fun executeAsync (Lokhttp3/Call;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 163 bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse( call: Call,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
111DB ; valid ; ; NV8 # 8.0 SHARADA SIGN SIDDHAM 111DC ; valid # 8.0 SHARADA HEADSTROKE 111DD..111DF ; valid ; ; NV8 # 8.0 SHARADA CONTINUATION SIGN..SHARADA SECTION MARK-2 111E0 ; disallowed # NA <reserved-111E0>
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Feb 10 11:25:47 GMT 2024 - 854.1K bytes - Viewed (2) -
.editorconfig
root = true [*] indent_size = 2 ij_continuation_indent_size = 2 charset = utf-8 trim_trailing_whitespace = true insert_final_newline = true [*.{kt, kts}]
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 185 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
private fun readHeaderBlock( length: Int, padding: Int, flags: Int, streamId: Int, ): List<Header> { continuation.left = length continuation.length = continuation.left continuation.padding = padding continuation.flags = flags continuation.streamId = streamId // TODO: Concat multi-value headers with 0x0, except COOKIE, which uses 0x3B, 0x20.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0)