- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for ListenableFuture (0.08 sec)
-
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* ListenableFuture}</a>. * * <p>This class is GWT-compatible. * * <h3>Purpose</h3> * * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of * asynchronous operations. You can chain them together manually with calls to methods like {@link * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* ListenableFuture}</a>. * * <p>This class is GWT-compatible. * * <h3>Purpose</h3> * * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of * asynchronous operations. You can chain them together manually with calls to methods like {@link * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* ListenableFuture}</a>. * * <p>This class is GWT-compatible. * * <h3>Purpose</h3> * * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of * asynchronous operations. You can chain them together manually with calls to methods like {@link * Futures#transform(ListenableFuture, com.google.common.base.Function, Executor) Futures.transform}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private static final class TestCallable implements AsyncCallable<@Nullable Void> { private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
*/ public static <V extends @Nullable Object> ListenableFuture<V> catching( ListenableFuture<? extends V> input, Class<Throwable> exceptionType, Function<? super Throwable, ? extends V> fallback, Executor executor) { return AbstractCatchingFuture.create(input, exceptionType, fallback, executor); } public static <V extends @Nullable Object> ListenableFuture<V> catchingAsync(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 24 17:45:05 UTC 2024 - 2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
* @author Nishant Thakkar * @since 10.0 */ @GwtIncompatible public class MockFutureListener implements Runnable { private final CountDownLatch countDownLatch; private final ListenableFuture<?> future; public MockFutureListener(ListenableFuture<?> future) { this.countDownLatch = new CountDownLatch(1); this.future = future; future.addListener(this, directExecutor()); } @Override public void run() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
implements ListenableFuture<V> { static final boolean GENERATE_CANCELLATION_CAUSES = false; /** * Tag interface marking trusted subclasses. This enables some optimizations. The implementation * of this interface must also be an AbstractFuture and must not override or expose for overriding * any of the public methods of ListenableFuture. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* #setFuture(ListenableFuture)}. */ private static final class AsyncTransformFuture< I extends @Nullable Object, O extends @Nullable Object> extends AbstractTransformFuture< I, O, AsyncFunction<? super I, ? extends O>, ListenableFuture<? extends O>> { AsyncTransformFuture(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 11K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java
/** Test for {@link ListenableFuture}. */ public class ListenableFutureTest extends TestCase { public void testNoNewApis() throws Exception { assertWithMessage( "Do not add new methods to ListenableFuture. Its API needs to continue to match the" + " version we released in a separate artifact com.google.guava:listenablefuture.") .that(ListenableFuture.class.getDeclaredMethods()) .asList()
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jun 15 19:48:16 UTC 2023 - 1.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
Future<V> future) { if (future instanceof ListenableFuture) { return (ListenableFuture<V>) future; } return new ListenableFutureAdapter<>(future); } /** * Submits a blocking task for the given {@link Future} to provide {@link ListenableFuture} * functionality. * * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0)