- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 23 for CONTINUATION (0.84 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2.kt
"HEADERS", "PRIORITY", "RST_STREAM", "SETTINGS", "PUSH_PROMISE", "PING", "GOAWAY", "WINDOW_UPDATE", "CONTINUATION", ) /** * Lookup table for valid flags for DATA, HEADERS, CONTINUATION. Invalid combinations are * represented in binary. */ private val FLAGS = arrayOfNulls<String>(0x40) // Highest bit flag is 0x20. private val BINARY =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 5.7K bytes - Click Count (0) -
internal/s3select/genmessage.go
fmt.Println(buf.Bytes()) } // Continuation Message // ==================== // Header specification // -------------------- // Continuation messages contain two headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png // // Payload specification // --------------------- // Continuation messages have no payload. func genContinuationMessage() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Click Count (0) -
cmd/api-resources.go
func getListObjectsV2Args(values url.Values) (prefix, token, startAfter, delimiter string, fetchOwner bool, maxkeys int, encodingType string, errCode APIErrorCode) { errCode = ErrNone // The continuation-token cannot be empty. if val, ok := values["continuation-token"]; ok { if len(val[0]) == 0 { errCode = ErrIncorrectContinuationToken return prefix, token, startAfter, delimiter, fetchOwner, maxkeys, encodingType, errCode } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.2K bytes - Click Count (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
import okio.IOException 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,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jun 19 04:20:30 GMT 2025 - 1.4K bytes - Click Count (1) -
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;Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 163 bytes - Click Count (0) -
cmd/api-resources_test.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 7.1K bytes - Click Count (0) -
okhttp/src/androidMain/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;
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Dec 30 23:28:56 GMT 2024 - 127.9K bytes - Click Count (1) -
doc/next/3-tools.md
The response file contains whitespace-separated arguments with support for single-quoted and double-quoted strings, escape sequences, and backslash-newline line continuation. The format is compatible with GCC's response file implementation to ensure interoperability with existing build systems. ### Go command {#go-command} `go test` now invokes the stdversion vet check by default.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Mar 19 02:58:52 GMT 2026 - 757 bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
private fun readHeaderBlock( length: Int, padding: Int, flags: Int, streamId: Int, ): List<Header> { continuation.left = length continuation.padding = padding continuation.flags = flags continuation.streamId = streamId // TODO: Concat multi-value headers with 0x0, except COOKIE, which uses 0x3B, 0x20.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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") } }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 14.4K bytes - Click Count (0)