- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for inputFutures (1.54 sec)
-
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) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
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) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} private FutureCombiner<@Nullable Object> futureCombiner() { return allMustSucceed ? Futures.whenAllSucceed(inputFutures()) : Futures.whenAllComplete(inputFutures()); } private ImmutableList<FluentFuture<?>> inputFutures() { return FluentIterable.from(inputs) .<FluentFuture<?>>transform(future -> future.future) .toList(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
} private FutureCombiner<@Nullable Object> futureCombiner() { return allMustSucceed ? Futures.whenAllSucceed(inputFutures()) : Futures.whenAllComplete(inputFutures()); } private ImmutableList<FluentFuture<?>> inputFutures() { return FluentIterable.from(inputs) .<FluentFuture<?>>transform(future -> future.future) .toList(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
*/ @CheckForNull @LazyInit ListenableFuture<? extends I> inputFuture; @CheckForNull @LazyInit F function; AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) { this.inputFuture = checkNotNull(inputFuture); this.function = checkNotNull(function); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (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); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
*/ @CheckForNull @LazyInit ListenableFuture<? extends V> inputFuture; @CheckForNull @LazyInit Class<X> exceptionType; @CheckForNull @LazyInit F fallback; AbstractCatchingFuture( ListenableFuture<? extends V> inputFuture, Class<X> exceptionType, F fallback) { this.inputFuture = checkNotNull(inputFuture); this.exceptionType = checkNotNull(exceptionType);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
*/ @CheckForNull @LazyInit ListenableFuture<? extends I> inputFuture; @CheckForNull @LazyInit F function; AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) { this.inputFuture = checkNotNull(inputFuture); this.function = checkNotNull(function); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (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); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.4K bytes - Viewed (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() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0)