- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 199 for dcancel (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
val server = serverListener.assertOpen() // Initiate a close on the client, which will schedule a hard cancel in 500 ms. val closeAtNanos = System.nanoTime() webSocket.close(1000, "goodbye", 500L) serverListener.assertClosing(1000, "goodbye") // Confirm that the hard cancel occurred after 500 ms. clientListener.assertFailure() val elapsedUntilFailure = System.nanoTime() - closeAtNanos
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} public void testCancelled() throws Exception { TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); assertFalse(task.isDone()); task.cancel(false); assertTrue(task.isDone()); assertTrue(task.isCancelled()); assertFalse(task.wasInterrupted()); assertThrows(CancellationException.class, () -> getDone(task)); verifyThreadWasNotInterrupted();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 7.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FailedPlan.kt
override val isReady = false override fun connectTcp() = result override fun connectTlsEtc() = result override fun handleSuccess() = error("unexpected call") override fun cancel() = error("unexpected cancel") override fun retry() = error("unexpected retry")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.5K bytes - Click Count (0) -
cmd/metacache-set.go
metaMu := &mc.mu rpc := mc.rpc cancel := mc.cancel defer func() { o.debugln(color.Green("saveMetaCacheStream:")+"err:", err) if err != nil && !errors.Is(err, io.EOF) { go mc.setErr(err.Error()) cancel() } }() defer cancel() // Save continuous updates go func() { var err error ticker := time.NewTicker(10 * time.Second)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* next task will wait for any running callable (or pending {@code Future} returned by an * {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code * cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code * Future} returned by this class, the next task may still have to wait.</i>. * <li>Once an {@code AsyncCallable} returns a {@code Future}, this class considers that task to
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/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()); assertThat(tryInternalFastPathGetFailure(future)).isNull();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 6.2K bytes - Click Count (0) -
internal/config/dns/operator_dns.go
u.RawQuery = q.Encode() return u.String(), nil } // Put - Adds DNS entries into operator webhook server func (c *OperatorDNS) Put(bucket string) error { ctx, cancel := context.WithTimeout(context.Background(), defaultOperatorContextTimeout) defer cancel() e, err := c.endpoint(bucket, false) if err != nil { return newError(bucket, err) } req, err := http.NewRequestWithContext(ctx, http.MethodPost, e, nil)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Nov 11 14:51:43 GMT 2024 - 6.6K bytes - Click Count (0) -
src/test/java/jcifs/util/transport/RequestTest.java
void testIsCancelTrue() { // Test case for isCancel method when it returns true when(mockRequest.isCancel()).thenReturn(true); assertTrue(mockRequest.isCancel(), "isCancel should return true when mocked to do so."); verify(mockRequest, times(1)).isCancel(); } @Test void testIsCancelFalse() { // Test case for isCancel method when it returns false
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 3.6K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} 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());Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 6.1K bytes - Click Count (0) -
src/main/java/jcifs/internal/CommonServerMessageBlockRequest.java
/** * Gets the size of this message. * * @return the size of this message */ int size(); /** * Creates a cancel request for this request. * * @return create cancel request */ CommonServerMessageBlockRequest createCancel(); /** * Checks if chaining is allowed with the next request. *Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.4K bytes - Click Count (0)