- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for FutureCallback (0.08 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
addCallback(f, callback, directExecutor()); f.setException(e); } public void testCancel() { SettableFuture<String> f = SettableFuture.create(); FutureCallback<String> callback = new FutureCallback<String>() { private final Object monitor = new Object(); private boolean called = false; @Override public void onSuccess(String result) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 15:59:55 GMT 2026 - 6.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
addCallback(f, callback, directExecutor()); f.setException(e); } public void testCancel() { SettableFuture<String> f = SettableFuture.create(); FutureCallback<String> callback = new FutureCallback<String>() { private final Object monitor = new Object(); private boolean called = false; @Override public void onSuccess(String result) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 15:59:55 GMT 2026 - 6.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
} public void testAddCallback() { FluentFuture<String> f = FluentFuture.from(immediateFuture("a")); boolean[] called = new boolean[1]; f.addCallback( new FutureCallback<String>() { @Override public void onSuccess(String result) { called[0] = true; } @Override public void onFailure(Throwable t) {} },
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
} public void testAddCallback() { FluentFuture<String> f = FluentFuture.from(immediateFuture("a")); boolean[] called = new boolean[1]; f.addCallback( new FutureCallback<String>() { @Override public void onSuccess(String result) { called[0] = true; } @Override public void onFailure(Throwable t) {} },
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
public static <V extends @Nullable Object> void addCallback( ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) { Preconditions.checkNotNull(callback); future.addListener(new CallbackListener<V>(future, callback), executor); } /** See {@link #addCallback(ListenableFuture, FutureCallback, Executor)} for behavioral notes. */
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
checkNotNull(closingExecutor); ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); Futures.addCallback( future, new FutureCallback<@Nullable AutoCloseable>() { @Override public void onSuccess(@Nullable AutoCloseable result) { closingFuture.state.closeables.closer.eventuallyClose(result, closingExecutor); }
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)