- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 20 for setFuture (0.06 seconds)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// cancellation can interleave in 3 ways // 1. prior to setFuture // 2. after setFuture before set() on the future assigned // 3. after setFuture and set() are called but before the listener completes. if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) { // If setFuture fails or set on the future fails then it must be because that future was // cancelledCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<String> nested = SettableFuture.create(); assertTrue(future.setFuture(nested)); // Later attempts to set the future should return false. assertFalse(future.set("x")); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.create())); // Check that the future has been set properly. assertFalse(future.isDone());
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertCancelled(future, true); } public void testSetFuturePending() throws Exception { assertThat(future.setFuture(delegate)).isTrue(); assertSetAsynchronously(future); } public void testSetFutureThenCancel() throws Exception { assertThat(future.setFuture(delegate)).isTrue(); assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue(); assertCancelled(future, false);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 15.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<String> nested = SettableFuture.create(); assertTrue(future.setFuture(nested)); // Later attempts to set the future should return false. assertFalse(future.set("x")); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.create())); // Check that the future has been set properly. assertFalse(future.isDone());
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// cancellation can interleave in 3 ways // 1. prior to setFuture // 2. after setFuture before set() on the future assigned // 3. after setFuture and set() are called but before the listener completes. if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) { // If setFuture fails or set on the future fails then it must be because that future was // cancelledCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
@Override public boolean setException(Throwable throwable) { return super.setException(throwable); } @CanIgnoreReturnValue @Override public boolean setFuture(ListenableFuture<? extends V> future) { return super.setFuture(future); } private SettableFuture() {}
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/SettableFuture.java
@Override public boolean setException(Throwable throwable) { return super.setException(throwable); } @CanIgnoreReturnValue @Override public boolean setFuture(ListenableFuture<? extends V> future) { return super.setFuture(future); } private SettableFuture() {}
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between nowCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between nowCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java
import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible @NullUnmarked public class TrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 1.2K bytes - Click Count (0)