- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for ListenableFuture (0.08 sec)
-
futures/listenablefuture1/pom.xml
- If users want only ListenableFuture, they depend on listenablefuture-1.0. - If users want all of Guava, they depend on guava, which, as of Guava 27.0, depends on listenablefuture-9999.0-empty-to-avoid-conflict-with-guava. The 9999.0-... version number is enough for some build systems (notably, Gradle) to select that empty artifact over the "real" listenablefuture-1.0 -- avoiding aRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Oct 02 19:27:26 UTC 2025 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
} FluentFuture() {} /** * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}. * * <p>If the given {@code ListenableFuture} is already a {@code FluentFuture}, it is returned * directly. If not, it is wrapped in a {@code FluentFuture} that delegates all calls to the * original {@code ListenableFuture}. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
android/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!");
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K 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!");
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K 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) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
@SafeVarargs public static <V extends @Nullable Object> ListenableFuture<List<V>> allAsList( ListenableFuture<? extends V>... futures) { ListenableFuture<List<@Nullable V>> nullable = new ListFuture<V>(ImmutableList.copyOf(futures), true); // allAsList ensures that it fills the output list with V instances. @SuppressWarnings("nullness") ListenableFuture<List<V>> nonNull = nullable; return nonNull; }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
android/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 Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 16.2K 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);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 6.4K bytes - Viewed (0) -
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);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 6.4K 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)}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 13:51:27 UTC 2025 - 96.9K bytes - Viewed (0)