- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for callAsync (0.05 seconds)
-
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( (closer, peeker) -> { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
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( (closer, peeker) -> { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try {
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/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); } /**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)