- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for FutureCombiner (0.1 seconds)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
} /** * Creates a {@link FutureCombiner} that processes the completed futures whether or not they're * successful. * * <p>Any failures from the input futures will not be propagated to the returned future. * * @since 20.0 */ public static <V extends @Nullable Object> FutureCombiner<V> whenAllComplete(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} }; ClosingFuture<V> derived = new ClosingFuture<>(futureCombiner().callAsync(asyncCallable, executor)); derived.state.closeables.add(closeables, directExecutor()); return derived; } private FutureCombiner<@Nullable Object> futureCombiner() { return allMustSucceed ? Futures.whenAllSucceed(inputFutures())Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AsyncCallable.java
import java.util.concurrent.Future; import org.jspecify.annotations.Nullable; /** * Computes a value, possibly asynchronously. For an example usage and more information, see {@link * Futures.FutureCombiner#callAsync(AsyncCallable, java.util.concurrent.Executor)}. * * <p>Much like {@link java.util.concurrent.Callable}, but returning a {@link ListenableFuture} * result. * * @since 20.0 */ @GwtCompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0)