Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 102 for Continuation (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top