- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 14 for CONTINUATION (0.06 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) -
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) -
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) -
src/main/java/jcifs/internal/smb1/trans2/Trans2FindNext2.java
import jcifs.Configuration; import jcifs.internal.smb1.trans.SmbComTransaction; import jcifs.internal.util.SMBUtil; import jcifs.util.Hexdump; /** * Trans2 FindNext2 request message for SMB1 directory enumeration continuation. * This class implements the TRANS2_FIND_NEXT2 transaction to retrieve subsequent * directory entries after a Trans2FindFirst2 request, supporting large directory listings. */
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 4.5K bytes - Click Count (0) -
cmd/object-api-listobjects_test.go
t, _ := t1.(*testing.T) testBuckets := []string{ // This bucket is used for testing ListObject operations. "test-bucket-list-object-continuation-1", "test-bucket-list-object-continuation-2", } for _, bucket := range testBuckets { err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error())Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 76.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/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() { if (closed) return closed = true messageInflater?.closeQuietly()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/api/WebApiManagerTest.java
assertFalse(chain.wasDoFilterCalled()); } @Test public void test_process_withChainContinuation() throws IOException, ServletException { // Test process with chain continuation ChainingWebApiManager manager = new ChainingWebApiManager(); TestHttpServletRequest request = new TestHttpServletRequest(); TestHttpServletResponse response = new TestHttpServletResponse();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 26.9K bytes - Click Count (0)