- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for FluentFuture (1.02 sec)
-
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
return super.cancel(mayInterruptIfRunning); } } FluentFuture() {} /** * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}. * * <p>If the given {@code ListenableFuture} is already a {@code FluentFuture}, it is returned * directly. If not, it is wrapped in a {@code FluentFuture} that delegates all calls to the * original {@code ListenableFuture}. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ListenableFuture<String> f = FluentFuture.from(SettableFuture.create()); assertThat(FluentFuture.from(f)).isSameInstanceAs(f); } public void testFromNonFluentFuture() throws Exception { ListenableFuture<String> f = new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {}; verify(!(f instanceof FluentFuture)); assertThat(FluentFuture.from(f).get()).isEqualTo("a");
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java
import com.google.common.annotations.J2ktIncompatible; import org.jspecify.annotations.Nullable; /** * Hidden superclass of {@link FluentFuture} that provides us a place to declare special GWT * versions of the {@link FluentFuture#catching(Class, com.google.common.base.Function) * FluentFuture.catching} family of methods. Those versions have slightly different signatures. */ @GwtCompatible @J2ktIncompatible // Super-sourcedRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 1.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
private final CloseableList closeables; private final FluentFuture<V> future; private ClosingFuture(ListenableFuture<V> future) { this(future, new CloseableList()); } private ClosingFuture(ListenableFuture<V> future, CloseableList closeables) { this.future = FluentFuture.from(future); this.closeables = closeables; } /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 13:51:27 UTC 2025 - 96.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* should throw IllegalStateException only when they use static state. * * Why do we deviate here? The answer: We want for fluentFuture.getDone() to throw the same * exception as Futures.getDone(fluentFuture). */ checkState(future.isDone(), "Future was expected to be done: %s", future); return getUninterruptibly(future); } /**Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0)