- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for FluentFuture (0.05 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 Sep 05 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
/** * Tests for {@link FluentFuture}. The tests cover only the basics for the API. The actual logic is * tested in {@link FuturesTest}. */ @NullMarked @GwtCompatible public class FluentFutureTest extends TestCase { @SuppressWarnings({"deprecation", "InlineMeInliner"}) // test of a deprecated method public void testFromFluentFuture() { FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 5.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform} * (or {@link FluentFuture#transform(com.google.common.base.Function, Executor) * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks * automate the process, often adding features like monitoring, debugging, and cancellation.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 97.8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform} * (or {@link FluentFuture#transform(com.google.common.base.Function, Executor) * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks * automate the process, often adding features like monitoring, debugging, and cancellation.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform} * (or {@link FluentFuture#transform(com.google.common.base.Function, Executor) * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks * automate the process, often adding features like monitoring, debugging, and cancellation.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
* * <p>This should be used in preference to {@link ListenableFutureTask} when possible for * performance reasons. */ @GwtCompatible class TrustedListenableFutureTask<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> implements RunnableFuture<V> { static <V extends @Nullable Object> TrustedListenableFutureTask<V> create( AsyncCallable<V> callable) { return new TrustedListenableFutureTask<>(callable);
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/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 Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0)