- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for addCallback (0.06 sec)
-
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
MockCallback callback = new MockCallback("foo"); addCallback(f, callback, directExecutor()); f.set("foo"); } public void testExecutorSuccess() { CountingSameThreadExecutor ex = new CountingSameThreadExecutor(); SettableFuture<String> f = SettableFuture.create(); MockCallback callback = new MockCallback("foo"); Futures.addCallback(f, callback, ex); f.set("foo"); assertEquals(1, ex.runCount);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 6.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* @param executor The executor to run {@code callback} when the future completes. */ public final void addCallback(FutureCallback<? super V> callback, Executor executor) { Futures.addCallback(this, callback, executor); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
// TODO(cpovirk): Test forwarding more extensively. } public void testAddCallback() { FluentFuture<String> f = FluentFuture.from(immediateFuture("a")); final boolean[] called = new boolean[1]; f.addCallback( new FutureCallback<String>() { @Override public void onSuccess(String result) { called[0] = true; } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* @since 10.0 */ public static <V extends @Nullable Object> void addCallback( final ListenableFuture<V> future, final 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. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
* @since 10.0 */ public static <V extends @Nullable Object> void addCallback( final ListenableFuture<V> future, final 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. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* <li>If an exception propagates out of a {@code Runnable}, it is not necessarily seen by any * {@code UncaughtExceptionHandler} for the thread. For example, if the callback passed to * {@link Futures#addCallback} throws an exception, that exception will be typically be * logged by the {@link ListenableFuture} implementation, even if the thread is configured
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 44.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
ListenableFuture<C> future, final Executor closingExecutor) { checkNotNull(closingExecutor); final ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); Futures.addCallback( future, new FutureCallback<@Nullable AutoCloseable>() { @Override public void onSuccess(@CheckForNull AutoCloseable result) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 08 19:36:35 UTC 2024 - 98.5K bytes - Viewed (0)