- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 32 for immediateFuture (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*} * family. <b>Avoid</b> creating a mock or stub {@code Future}. Mock and stub implementations are * fragile because they assume that only certain methods will be called and because they oftenCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*} * family. <b>Avoid</b> creating a mock or stub {@code Future}. Mock and stub implementations are * fragile because they assume that only certain methods will be called and because they oftenCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0)