- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 122 for cartel (0.23 sec)
-
cmd/admin-handlers-users-race_test.go
func(t *testing.T) { runAllIAMConcurrencyTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestDeleteUserRace(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second) defer cancel() bucket := getRandomBucketName() err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket creat error: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/SuspendCallTest.kt
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 5.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
} public void testListenerCalledOnCancelFromRunning() throws Exception { exec.execute(task); runLatch.await(); // Task has started up, cancel it while it's running. task.cancel(true); assertTrue(task.isDone()); assertTrue(task.isCancelled()); assertEquals(1, taskLatch.getCount()); // Wait for the listeners to be called.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone()); assertFalse(future.isCancelled());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
docs/em/docs/tutorial/extra-models.md
### `Union` đ 3ī¸âŖ.1ī¸âŖ0ī¸âŖ đ đŧ đĨ đļââī¸ `Union[PlaneItem, CarItem]` đ˛ â `response_model`. âŠī¸ đĨ đļââī¸ âĢī¸ **đ˛ â** âŠī¸ đŽ âĢī¸ **đ â**, đĨ âī¸ âī¸ `Union` đ 3ī¸âŖ.1ī¸âŖ0ī¸âŖ. đĨ âĢī¸ đ â đĨ đĒ âī¸ âī¸ ⸠â¸,: ```Python some_variable: PlaneItem | CarItem ``` âī¸ đĨ đĨ đŽ đ `response_model=PlaneItem | CarItem` đĨ đ đ¤ â, âŠī¸ đ đ đ đ **â đ ī¸** đ `PlaneItem` & `CarItem` âŠī¸ đŦ đ đ â. ## đ đˇ
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 6.8K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
* the event source has already been closed or canceled. */ fun cancel() fun interface Factory { /** * Creates a new event source and immediately returns it. Creating an event source initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
tests/test_tutorial/test_extra_models/test_tutorial003_py310.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Aug 04 20:47:07 GMT 2023 - 5.3K bytes - Viewed (0) -
docs/en/docs/tutorial/extra-models.md
=== "Python 3.10+" ```Python hl_lines="1 14-15 18-20 33" {!> ../../../docs_src/extra_models/tutorial003_py310.py!} ``` === "Python 3.8+"
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 7.7K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
fun noNewExchangesOnConnection() { codec.carrier.noNewExchanges() } fun cancel() { codec.cancel() } /** * Revoke this exchange's access to streams. This is necessary when a follow-up request is * required but the preceding exchange hasn't completed yet. */ fun detachWithViolence() { codec.cancel() call.messageDone(this, requestDone = true, responseDone = true, e = null) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
System.clearProperty("guava.concurrent.generate_cancellation_cause"); } public void testCancel_notDoneNoInterrupt() throws Exception { Future<?> future = newFutureInstance(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertNull(tryInternalFastPathGetFailure(future)); CancellationException e = assertThrows(CancellationException.class, () -> future.get());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0)