- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for resultCh (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
func (ifr *inFlightRequest) launch(doer doer, client *http.Client) { go func() { result := doer.Do(client, func(httptrace.GotConnInfo) {}, ifr.url, 0) ifr.resultCh <- result }() } func (ifr *inFlightRequest) unblockAndWaitForResult(t *testing.T) result { close(ifr.blockedCh) var resultGot result select { case resultGot = <-ifr.resultCh: return resultGot case <-time.After(wait.ForeverTestTimeout):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
defer func() { result := result{} result.err = recover() if result.err != nil { // Same as stdlib http server code. Manually allocate stack // trace buffer size to prevent excessively large logs const size = 64 << 10 buf := make([]byte, size) buf = buf[:goruntime.Stack(buf, false)] result.stackTrace = string(buf) } resultCh <- result }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/AbstractJUnitTestExecutionIntegrationTest.groovy
then: TestFile results1 = testDirectory.file('build/test-results/test/TEST-org.gradle.SomeTest.xml') TestFile results2 = testDirectory.file('build/test-results/test/TEST-org.gradle.SomeTest2.xml') results1.assertIsFile() results2.assertIsFile() assertThat(results1.linesThat(containsString('VM START TIME =')).get(0), equalTo(results2.linesThat(containsString('VM START TIME =')).get(0)))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Apr 06 02:21:33 UTC 2024 - 19.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ComponentState.java
DefaultBuildableComponentResolveResult result = new DefaultBuildableComponentResolveResult(); resolver.resolve(componentIdentifier, componentOverrideMetadata, result); if (result.getFailure() != null) { metadataResolveFailure = result.getFailure(); return; } resolveState = result.getState(); graphResolveState = result.getGraphState(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 17K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/StreamingResolutionResultBuilderTest.groovy
import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.of import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.requested import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.root
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:29:40 UTC 2024 - 11.5K bytes - Viewed (0) -
docs/de/docs/advanced/settings.md
execute ->> code: gib das Resultat zurück end rect rgba(0, 255, 0, .1) code ->> function: say_hi(name="Rick", salutation="Mr.") function ->> execute: führe Code der Funktion aus execute ->> code: gib das Resultat zurück end rect rgba(0, 255, 255, .1) code ->> function: say_hi(name="Rick") function ->> code: gib das gespeicherte Resultat zurück end
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 20:17:14 UTC 2024 - 17.8K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token_test.go
} // Return if an error is expected if test.expectedError { return } // Validate the resulted kubeconfig kubeconfigBytes, err = clientcmd.Write(*kubeconfig) if err != nil { t.Fatalf("cannot marshal resulted kubeconfig %v", err) } if string(kubeconfigBytes) != expectedKubeconfig { t.Error("unexpected kubeconfig") diff := difflib.UnifiedDiff{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/convert_tensor_test.cc
EXPECT_THAT( attribute, AllOf(Eq(mlir::DenseElementsAttr::get( mlir::RankedTensorType::get({1ULL << 35}, builder.getF32Type()), 42.0f)), ResultOf(IsSplat, IsTrue()))); } TEST(ConvertTensorProtoTest, NonSplatTensor) { TensorProto proto = tensor::CreateTensorProto<float>( /*values=*/{1.0f, 2.0f, 3.0f, 4.0f}, /*shape=*/{2, 2});
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 10.4K bytes - Viewed (0) -
docs/fr/docs/async.md
```Python results = await some_library() ``` Alors, déclarez vos *fonctions de chemins* avec `async def` comme ceci : ```Python hl_lines="2" @app.get('/') async def read_results(): results = await some_library() return results ``` !!! note Vous pouvez uniquement utiliser `await` dans les fonctions créées avec `async def`.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Mar 31 23:52:53 UTC 2024 - 24K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/quantization/quantization_context.cc
} // If there are no immutable states, use the result's state if it is the // only one result and has parameters propagated. if (op->getNumResults() == 1 && mutable_results_num == 1) { return mutable_states.back()->params; } // Use the first propagated state to quantize the rest operands and results. if (!mutable_states.empty()) return mutable_states.front()->params;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 08 01:38:03 UTC 2024 - 13.1K bytes - Viewed (0)