- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 105 for ListenableFuture (0.26 sec)
-
android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java
* already constructed {@link ListenableFuture} as the delegate. * * @since 9.0 */ public abstract static class SimpleForwardingListenableFuture<V extends @Nullable Object> extends ForwardingListenableFuture<V> { private final ListenableFuture<V> delegate; protected SimpleForwardingListenableFuture(ListenableFuture<V> delegate) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Mar 04 12:23:41 GMT 2022 - 2.4K 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(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 08 20:30:27 GMT 2022 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
extends InterruptibleTask<ListenableFuture<V>> { private final AsyncCallable<V> callable; TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable) { this.callable = checkNotNull(callable); } @Override final boolean isDone() { return TrustedListenableFutureTask.this.isDone(); } @Override ListenableFuture<V> runInterruptibly() throws Exception {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
} /** * Override to return a chaining listenableFuture that returns the result of getSuccessfulResult() * when inputFuture returns VALID_INPUT_DATA, and sets the exception to EXCEPTION in all other * cases. */ protected abstract ListenableFuture<T> buildChainingFuture(ListenableFuture<Integer> inputFuture); /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
private CountDownLatch funcIsWaitingLatch; // Signals the function so it will complete private CountDownLatch funcCompletionLatch; @Override protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { outputFuture = SettableFuture.create(); funcIsWaitingLatch = new CountDownLatch(1); funcCompletionLatch = new CountDownLatch(1);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
extends CombinedFutureInterruptibleTask<ListenableFuture<V>> { private final AsyncCallable<V> callable; AsyncCallableInterruptibleTask(AsyncCallable<V> callable, Executor listenerExecutor) { super(listenerExecutor); this.callable = checkNotNull(callable); } @Override ListenableFuture<V> runInterruptibly() throws Exception { ListenableFuture<V> result = callable.call();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.awaitTermination(timeout, unit); } @Override public <T> ListenableFuture<T> submit(Callable<T> task) { Preconditions.checkNotNull(task, "task must not be null!"); return delegate.submit(task); } @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { Preconditions.checkNotNull(task, "task must not be null!");
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
public Class<?> loadClass(String name) throws ClassNotFoundException { if (name.startsWith(concurrentPackage) // Use other classloader for ListenableFuture, so that the objects can interact && !ListenableFuture.class.getName().equals(name)) { synchronized (loadedClasses) { Class<?> toReturn = loadedClasses.get(name); if (toReturn == null) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* <li>Return a {@code ClosingFuture}. To turn a {@link ListenableFuture} into a {@code * ClosingFuture} call {@link #from(ListenableFuture)}. * <li>In case this step doesn't create new closeables, you can adapt an API that returns a * {@link ListenableFuture} to return a {@code ClosingFuture} by wrapping it with a call to * {@link #withoutCloser(AsyncFunction)}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault final class TimeoutFuture<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> { static <V extends @Nullable Object> ListenableFuture<V> create( ListenableFuture<V> delegate, long time, TimeUnit unit, ScheduledExecutorService scheduledExecutor) { TimeoutFuture<V> result = new TimeoutFuture<>(delegate);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0)