- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 105 for ListenableFuture (0.26 sec)
-
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 Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java
new UndeclaredThrowableException(EXCEPTION); @Override protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { return transform(inputFuture, new ComposeFunction(), directExecutor()); } @Override protected String getSuccessfulResult() { return RESULT_DATA; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Jun 28 16:27:15 GMT 2018 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java
* * <h3>Extension</h3> * * If you want a class like {@code FluentFuture} but with extra methods, we recommend declaring your * own subclass of {@link ListenableFuture}, complete with a method like {@link #from} to adapt an * existing {@code ListenableFuture}, implemented atop a {@link ForwardingListenableFuture} that * forwards to that future and adds the desired methods. */ @GwtCompatible @ElementTypesAreNonnullByDefault
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 05 22:27:35 GMT 2021 - 2.5K 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}. */
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) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
} public void testFromFluentFuturePassingAsNonFluent() { ListenableFuture<String> f = FluentFuture.from(SettableFuture.<String>create()); assertThat(FluentFuture.from(f)).isSameInstanceAs(f); } public void testFromNonFluentFuture() throws Exception { ListenableFuture<String> f = new SimpleForwardingListenableFuture<String>(immediateFuture("a")) {};
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/SettableFuture.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any * other {@code Future}, be {@linkplain #cancel cancelled}. * * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 2.4K 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!");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
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 Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
/** * Abstract test case parent for anything implementing {@link ListenableFuture}. Tests the two get * methods and the addListener method. * * @author Sven Mawson * @since 10.0 */ @GwtIncompatible public abstract class AbstractListenableFutureTest extends TestCase { protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K 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. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0)