- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for setFuture (0.04 sec)
-
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.<String>create())); // Check that the future has been set properly. assertFalse(future.isDone());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 7.3K bytes - Viewed (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() {}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (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() {}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) { localTask.run(); } /* * In the Async case, we may have called setFuture(pendingFuture), in which case afterDone() * won't have been called yet. */ this.task = null; } @Override protected void afterDone() { super.afterDone();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 5.5K bytes - Viewed (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() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 1.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java
import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible @NullUnmarked public class UntrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 1.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture", future.getClass().getClassLoader().loadClass(ListenableFuture.class.getName())) .invoke(future, badFuture); CancellationException expected = assertThrows(CancellationException.class, () -> future.get());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture", future.getClass().getClassLoader().loadClass(ListenableFuture.class.getName())) .invoke(future, badFuture); CancellationException expected = assertThrows(CancellationException.class, () -> future.get());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* even with the above null checks.) */ timeoutFutureRef = null; if (delegate.isDone()) { timeoutFuture.setFuture(delegate); } else { try { @RetainedLocalRef ScheduledFuture<?> timer = timeoutFuture.timer; timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0)