- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for inputFuture (0.06 seconds)
-
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
*/ @LazyInit @Nullable ListenableFuture<? extends I> inputFuture; @LazyInit @Nullable F function; AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) { this.inputFuture = checkNotNull(inputFuture); this.function = checkNotNull(function); } @Override @SuppressWarnings({
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
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); listener = new MockFutureListener(resultFuture); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 3.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
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); listener = new MockFutureListener(resultFuture); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 3.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
*/ @LazyInit @Nullable ListenableFuture<? extends V> inputFuture; @LazyInit @Nullable Class<X> exceptionType; @LazyInit @Nullable F fallback; AbstractCatchingFuture( ListenableFuture<? extends V> inputFuture, Class<X> exceptionType, F fallback) { this.inputFuture = checkNotNull(inputFuture); this.exceptionType = checkNotNull(exceptionType); this.fallback = checkNotNull(fallback);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Sep 11 18:28:58 GMT 2025 - 9K bytes - Click Count (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; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 2.2K bytes - Click Count (0) -
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; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 2.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
@Override protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { outputFuture = SettableFuture.create(); funcIsWaitingLatch = new CountDownLatch(1); funcCompletionLatch = new CountDownLatch(1); return transformAsync(inputFuture, new ChainingFunction(), directExecutor()); } @Override protected String getSuccessfulResult() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
@Override protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { outputFuture = SettableFuture.create(); funcIsWaitingLatch = new CountDownLatch(1); funcCompletionLatch = new CountDownLatch(1); return transformAsync(inputFuture, new ChainingFunction(), directExecutor()); } @Override protected String getSuccessfulResult() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
private final @Nullable ListenableFuture<? extends T>[] inputFutures; private volatile int delegateIndex = 0; private InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures) { this.inputFutures = inputFutures; incompleteOutputCount = new AtomicInteger(inputFutures.length); } private void recordOutputCancellation(boolean interruptIfRunning) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
AsyncFunction<String, Integer> function = unused -> { throw error; }; SettableFuture<String> inputFuture = SettableFuture.create(); ListenableFuture<Integer> outputFuture = transformAsync(inputFuture, function, directExecutor()); inputFuture.set("value"); ExecutionException expected = assertThrows(ExecutionException.class, () -> getDone(outputFuture));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0)