- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Cancellation (0.58 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} } /** A special value to represent cancellation and the 'wasInterrupted' bit. */ private static final class Cancellation { // constants to use when GENERATE_CANCELLATION_CAUSES = false @CheckForNull static final Cancellation CAUSELESS_INTERRUPTED; @CheckForNull static final Cancellation CAUSELESS_CANCELLED; static { if (GENERATE_CANCELLATION_CAUSES) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
} } /** A special value to represent cancellation and the 'wasInterrupted' bit. */ private static final class Cancellation { // constants to use when GENERATE_CANCELLATION_CAUSES = false @CheckForNull static final Cancellation CAUSELESS_INTERRUPTED; @CheckForNull static final Cancellation CAUSELESS_CANCELLED; static { if (GENERATE_CANCELLATION_CAUSES) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonFactory.java
// This notifies the cancellation handler that a worker daemon has been in use during this build session. If the // build session is cancelled, we can't guarantee that all worker daemons are in a safe state, so the cancellation // handler will stop any long-lived worker daemons. If a worker is not used during this session (i.e. this method
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 13:20:59 UTC 2024 - 3.4K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java
import org.junit.jupiter.api.Test; import org.mockito.Mockito; import static org.junit.jupiter.api.Assertions.assertThrows; class SimplexTransferListenerTest { @Test void cancellation() throws InterruptedException { TransferListener delegate = new TransferListener() { @Override public void transferInitiated(TransferEvent event) throws TransferCancelledException {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 4.9K bytes - Viewed (0) -
doc/next/6-stdlib/99-minor/net/63116.md
The [DNSError] type now wraps errors caused by timeouts or cancellation. For example, `errors.Is(someDNSErr, context.DeadlineExceedeed)`
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 24 13:37:36 UTC 2024 - 198 bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* Futures#transform(ListenableFuture, Function, Executor) Futures.transform}, but you will often * find it easier to use a framework. Frameworks automate the process, often adding features like * monitoring, debugging, and cancellation. Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
src/context/context.go
} c := &cancelCtx{} c.propagateCancel(parent, c) return c } // Cause returns a non-nil error explaining why c was canceled. // The first cancellation of c or one of its parents sets the cause. // If that cancellation happened via a call to CancelCauseFunc(err), // then [Cause] returns err. // Otherwise Cause(c) returns the same value as c.Err(). // Cause returns nil if c has not been canceled yet.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
* Futures#transform(ListenableFuture, Function, Executor) Futures.transform}, but you will often * find it easier to use a framework. Frameworks automate the process, often adding features like * monitoring, debugging, and cancellation. Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
.that(step3.statusFuture().isCancelled()) .isTrue(); // Its closeable is still open. assertStillOpen(closeable3); // Step 4 is not cancelled, because it caught the cancellation. assertWithMessage("step4.statusFuture().isCancelled()") .that(step4.statusFuture().isCancelled()) .isFalse(); // Its closeable isn't closed yet. assertStillOpen(closeable4);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
.that(step3.statusFuture().isCancelled()) .isTrue(); // Its closeable is still open. assertStillOpen(closeable3); // Step 4 is not cancelled, because it caught the cancellation. assertWithMessage("step4.statusFuture().isCancelled()") .that(step4.statusFuture().isCancelled()) .isFalse(); // Its closeable isn't closed yet. assertStillOpen(closeable4);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0)