- 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-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 May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 1.5K bytes - Viewed (0) -
.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 May 03 11:42:14 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLandroidx/lifecycle/LifecycleKt;->createCoroutineUnintercepted(Lkotlin/jvm/functions/Function2;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation; HSPLandroidx/lifecycle/LifecycleKt;->intercepted(Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation; HSPLandroidx/lifecycle/LifecycleOwnerKt;->getLifecycleScope(Landroidx/lifecycle/LifecycleOwner;)Landroidx/lifecycle/LifecycleCoroutineScope;
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/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
import okhttp3.internal.http2.Http2.FLAG_END_STREAM import okhttp3.internal.http2.Http2.FLAG_NONE import okhttp3.internal.http2.Http2.INITIAL_MAX_FRAME_SIZE import okhttp3.internal.http2.Http2.TYPE_CONTINUATION import okhttp3.internal.http2.Http2.TYPE_DATA import okhttp3.internal.http2.Http2.TYPE_GOAWAY import okhttp3.internal.http2.Http2.TYPE_HEADERS import okhttp3.internal.http2.Http2.TYPE_PING
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/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
}.also { expected -> assertThat(expected.message).isEqualTo("Unexpected rsv1 flag") } } @Test fun reservedFlag1IsUnsupportedForContinuationFrames() { data.write("c000".decodeHex()) // Empty continuation, flag 1 set. assertFailsWith<ProtocolException> { clientReaderWithCompression.processNextFrame() }.also { expected -> assertThat(expected.message).isEqualTo("Unexpected rsv1 flag") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
* bytes represent the length. If this value is [PAYLOAD_LONG], the next eight bytes * represent the length. */ internal const val B1_MASK_LENGTH = 127 internal const val OPCODE_CONTINUATION = 0x0 internal const val OPCODE_TEXT = 0x1 internal const val OPCODE_BINARY = 0x2 internal const val OPCODE_CONTROL_CLOSE = 0x8 internal const val OPCODE_CONTROL_PING = 0x9
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
* Fix: Always configure NPN headers. This fixes connectivity to `https://facebook.com` when SPDY and HTTP/2 are both disabled. Otherwise an unexpected NPN response is received and OkHttp crashes. * Fix: Write continuation frames when HPACK data is larger than 16383 bytes. * Fix: Don't drop uncaught exceptions thrown in async calls. * Fix: Throw an exception eagerly when a request body is not legal. Previously
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0)