- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for addCallback (0.26 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);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Nov 15 16:33:21 GMT 2022 - 6.3K bytes - Viewed (0) -
android/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);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* rarely use it directly, in part because it does not provide direct access to the {@code Future} * result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * <pre>{@code * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FutureCallback.java
/** * A callback for accepting the results of a {@link java.util.concurrent.Future} computation * asynchronously. * * <p>To attach to a {@link ListenableFuture} use {@link Futures#addCallback}. * * @author Anthony Zana * @since 10.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface FutureCallback<V extends @Nullable Object> {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 05 22:27:35 GMT 2021 - 1.6K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* rarely use it directly, in part because it does not provide direct access to the {@code Future} * result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * <pre>{@code * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ListenableFuture.java
@JsOptional @Nullable IThenOnRejectedCallbackFn<? extends R> onRejected) { return new Promise<V>( (resolve, reject) -> { Futures.addCallback( this, new FutureCallback<V>() { @Override public void onSuccess(V value) { resolve.onInvoke(value);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Oct 24 18:27:19 GMT 2023 - 3.9K bytes - Viewed (1) -
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
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.7K bytes - Viewed (0) -
android/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); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
android/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
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.7K bytes - Viewed (0) -
android/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
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0)