- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for callAsync (0.06 sec)
-
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
*/ public <V extends @Nullable Object> ClosingFuture<V> callAsync( AsyncCombiningCallable<V> combiningCallable, Executor executor) { AsyncCallable<V> asyncCallable = new AsyncCallable<V>() { @Override public ListenableFuture<V> call() throws Exception { return new Peeker(inputs).callAsync(combiningCallable, 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) -
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 */ @FunctionalInterface
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
AtomicReference<ClosingFuture.Peeker> capturedPeeker = new AtomicReference<>(); ClosingFuture<TestCloseable> closingFuture = ClosingFuture.whenAllComplete(ImmutableList.of(input1, input2Failed)) .callAsync( new AsyncCombiningCallable<TestCloseable>() { @Override public ClosingFuture<TestCloseable> call(DeferredCloser closer, Peeker peeker)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 75.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
*/ public <V extends @Nullable Object> ClosingFuture<V> callAsync( AsyncCombiningCallable<V> combiningCallable, Executor executor) { AsyncCallable<V> asyncCallable = new AsyncCallable<V>() { @Override public ListenableFuture<V> call() throws Exception { return new Peeker(inputs).callAsync(combiningCallable, 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/AggregateFuture.java
* handleAllCompleted(), they will already have been nulled out. But in the case of * whenAll*().call*(), this future may be pending until the callback runs -- or even longer in * the case of callAsync(), which waits for the callback's returned future to complete. */ releaseResources(ALL_INPUT_FUTURES_PROCESSED); } /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* href="https://errorprone.info/bugpattern/FutureReturnValueIgnored">https://errorprone.info/bugpattern/FutureReturnValueIgnored</a>. */ public <C extends @Nullable Object> ListenableFuture<C> callAsync( AsyncCallable<C> combiner, Executor executor) { return new CombinedFuture<>(futures, allMustSucceed, executor, combiner); } /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0)