- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for SettableFuture (0.09 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
private Class<?> settableFutureClass; private Class<?> abstractFutureClass; @Override protected void setUp() throws Exception { // Load the "normal" copy of SettableFuture and related classes. SettableFuture<?> unused = SettableFuture.create(); // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
public void testFromFluentFuture() { FluentFuture<String> f = FluentFuture.from(SettableFuture.create()); assertThat(FluentFuture.from(f)).isSameInstanceAs(f); } public void testFromFluentFuturePassingAsNonFluent() { ListenableFuture<String> f = FluentFuture.from(SettableFuture.create()); assertThat(FluentFuture.from(f)).isSameInstanceAs(f); }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
protected static final Exception EXCEPTION = new Exception("Test exception"); protected SettableFuture<Integer> inputFuture; protected ListenableFuture<T> resultFuture; protected MockFutureListener listener; @Override protected void setUp() throws Exception { super.setUp(); inputFuture = SettableFuture.create(); resultFuture = buildChainingFuture(inputFuture);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } } public void testGetUnchecked_cancelled() { SettableFuture<String> future = SettableFuture.create(); future.cancel(true); assertThrows(CancellationException.class, () -> getUnchecked(future)); } public void testGetUnchecked_executionExceptionChecked() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } } public void testGetUnchecked_cancelled() { SettableFuture<String> future = SettableFuture.create(); future.cancel(true); assertThrows(CancellationException.class, () -> getUnchecked(future)); } public void testGetUnchecked_executionExceptionChecked() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 4.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
protected static final int SLOW_OUTPUT_VALID_INPUT_DATA = 2; protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3; private static final String RESULT_DATA = "SUCCESS"; private SettableFuture<String> outputFuture; // Signals that the function is waiting to complete private CountDownLatch funcIsWaitingLatch; // Signals the function so it will complete private CountDownLatch funcCompletionLatch;
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
protected static final int SLOW_OUTPUT_VALID_INPUT_DATA = 2; protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3; private static final String RESULT_DATA = "SUCCESS"; private SettableFuture<String> outputFuture; // Signals that the function is waiting to complete private CountDownLatch funcIsWaitingLatch; // Signals the function so it will complete private CountDownLatch funcCompletionLatch;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 6.4K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0)