- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 48 for ImmediateFuture (0.11 seconds)
-
android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java
/** Implementation of {@link Futures#immediateFuture}. */ @GwtCompatible // TODO(cpovirk): Make this final (but that may break Mockito spy calls). class ImmediateFuture<V extends @Nullable Object> implements ListenableFuture<V> { static final ListenableFuture<?> NULL = new ImmediateFuture<@Nullable Object>(null); private static final LazyLogger log = new LazyLogger(ImmediateFuture.class); @ParametricNullness private final V value;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
ClosingFuture.whenAllSucceed( ClosingFuture.eventuallyClosing(immediateFuture(closeable1), closingExecutor), ClosingFuture.from(immediateFuture("value2")), ClosingFuture.from(immediateFuture("value3")), ClosingFuture.from(immediateFuture("value4")), ClosingFuture.from(immediateFuture("value5"))) .call( (DeferredCloser closer,
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ListenableFuture<String> f = new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {}; verify(!(f instanceof FluentFuture)); assertThat(FluentFuture.from(f).get()).isEqualTo("a"); // TODO(cpovirk): Test forwarding more extensively. } public void testAddCallback() { FluentFuture<String> f = FluentFuture.from(immediateFuture("a")); boolean[] called = new boolean[1]; f.addCallback(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
ClosingFuture.whenAllSucceed( ClosingFuture.eventuallyClosing(immediateFuture(closeable1), closingExecutor), ClosingFuture.from(immediateFuture("value2")), ClosingFuture.from(immediateFuture("value3")), ClosingFuture.from(immediateFuture("value4")), ClosingFuture.from(immediateFuture("value5"))) .call( (DeferredCloser closer,
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ListenableFuture<String> f = new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {}; verify(!(f instanceof FluentFuture)); assertThat(FluentFuture.from(f).get()).isEqualTo("a"); // TODO(cpovirk): Test forwarding more extensively. } public void testAddCallback() { FluentFuture<String> f = FluentFuture.from(immediateFuture("a")); boolean[] called = new boolean[1]; f.addCallback(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
import static com.google.common.util.concurrent.ClassPathUtil.parseJavaClassPath; import static com.google.common.util.concurrent.Futures.getChecked; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
import static com.google.common.util.concurrent.ClassPathUtil.parseJavaClassPath; import static com.google.common.util.concurrent.Futures.getChecked; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
public void testGetUnchecked_success() { assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo"); } @J2ktIncompatible @GwtIncompatible // Thread.interrupt public void testGetUnchecked_interrupted() { Thread.currentThread().interrupt(); try { assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo"); assertTrue(Thread.currentThread().isInterrupted()); } finally {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 4.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
public void testGetUnchecked_success() { assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo"); } @J2ktIncompatible @GwtIncompatible // Thread.interrupt public void testGetUnchecked_interrupted() { Thread.currentThread().interrupt(); try { assertThat(getUnchecked(immediateFuture("foo"))).isEqualTo("foo"); assertTrue(Thread.currentThread().isInterrupted()); } finally {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 4.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
// Since holder.value is 2, applying 4 should yield 6. assertEquals(6, adder.apply(4).intValue()); ListenableFuture<Integer> immediateFuture = immediateFuture(4); Future<Integer> transformedFuture = transform(immediateFuture, adder, directExecutor()); // The composed future also yields 6. assertEquals(6, getDone(transformedFuture).intValue());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0)