- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 102 for Continuation (0.17 sec)
-
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/KtFe10TypeSystemCommonBackendContextForTypeMapping.kt
} return upperBounds.firstOrNull() ?: builtIns.nullableAnyType } override fun continuationTypeConstructor(): TypeConstructorMarker { val continuationFqName = StandardClassIds.Continuation.asSingleFqName() val foundClasses = resolveSession.getTopLevelClassifierDescriptors(continuationFqName, NoLookupLocation.FROM_IDE) return foundClasses.firstOrNull()?.typeConstructor
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:34 UTC 2024 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonCommandExecution.java
import org.gradle.launcher.daemon.context.DaemonContext; import org.gradle.launcher.daemon.protocol.Command; import java.util.LinkedList; import java.util.List; /** * A continuation style object used to model the execution of a command. * <p> * Facilitates processing “chains”, making it easier to break up processing logic into discrete {@link org.gradle.launcher.daemon.server.api.DaemonCommandAction actions}.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4K bytes - Viewed (0) -
src/net/textproto/textproto.go
// a server. // // [Pipeline], to manage pipelined requests and responses // in a client. // // [Reader], to read numeric response code lines, // key: value headers, lines wrapped with leading spaces // on continuation lines, and whole text blocks ending // with a dot on a line by itself. // // [Writer], to write dot-encoded text blocks. // // [Conn], a convenient packaging of [Reader], [Writer], and [Pipeline] for use
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
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 fun flagOverlapOn0x20() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K 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") } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 14.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/continue.go
return keyPrefix + cleaned[1:], c.ResourceVersion, nil default: return "", 0, fmt.Errorf("%w %v", ErrUnrecognizedEncodedVersion, c.APIVersion) } } // EncodeContinue returns a string representing the encoded continuation of the current query. func EncodeContinue(key, keyPrefix string, resourceVersion int64) (string, error) { nextKey := strings.TrimPrefix(key, keyPrefix) if nextKey == key {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 17:30:02 UTC 2022 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// ResourceVersion should be unset when setting continuation token. ResourceVersion: "", Predicate: pred(0, continueFromSecondItem), Recursive: true, } if err := store.GetList(ctx, "/pods", options, out); err != nil { t.Fatalf("Unable to get second page: %v", err) } if len(out.Continue) != 0 { t.Fatalf("Unexpected continuation token set") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/types.go
Limit int64 // Continue is a token returned by the server that lets a client retrieve chunks of results // from the server by specifying limit. The server may reject requests for continuation tokens // it does not recognize and will return a 410 error if the token can no longer be used because // it has expired. Continue string // `sendInitialEvents=true` may be set together with `watch=true`.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 09:55:40 UTC 2023 - 4.5K bytes - Viewed (0) -
src/net/textproto/reader.go
return line, nil } // ReadContinuedLine reads a possibly continued line from r, // eliding the final trailing ASCII white space. // Lines after the first are considered continuations if they // begin with a space or tab character. In the returned data, // continuation lines are separated from the previous line // only by a single space: the newline and leading white space // are removed. // // For example, consider this input: //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 22.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/roundtrip_test.go
{ name: "nonempty string", obj: "hello world", }, { name: "empty string", obj: "", }, { name: "string containing invalid UTF-8 sequence", obj: "\x80", // first byte is a continuation byte }, { name: "true", obj: true, }, { name: "false", obj: false, }, { name: "int64", obj: int64(5), }, { name: "int64 max",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 21:48:12 UTC 2024 - 7.1K bytes - Viewed (0)