- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for collectOneValue (0.21 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* cancelled. For details on when this is called, see {@link #collectOneValue}. */ private void collectValueFromNonCancelledFuture(int index, Future<? extends InputT> future) { try { // We get the result, even if collectOneValue is a no-op, so that we can fail fast. collectOneValue(index, getDone(future)); } catch (ExecutionException e) { handleException(e.getCause());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFuture.java
* cancelled. For details on when this is called, see {@link #collectOneValue}. */ private void collectValueFromNonCancelledFuture(int index, Future<? extends InputT> future) { try { // We get the result, even if collectOneValue is a no-op, so that we can fail fast. collectOneValue(index, getDone(future)); } catch (ExecutionException e) { handleException(e.getCause());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CollectionFuture.java
// Populate the results list with null initially. for (int i = 0; i < futures.size(); ++i) { values.add(null); } this.values = values; } @Override final void collectOneValue(int index, @ParametricNullness V returnValue) { List<@Nullable Present<V>> localValues = values; if (localValues != null) { localValues.set(index, new Present<>(returnValue)); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
// Populate the results list with null initially. for (int i = 0; i < futures.size(); ++i) { values.add(null); } this.values = values; } @Override final void collectOneValue(int index, @ParametricNullness V returnValue) { List<@Nullable Present<V>> localValues = values; if (localValues != null) { localValues.set(index, new Present<>(returnValue)); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
Callable<V> callable) { super(futures, allMustSucceed, false); this.task = new CallableInterruptibleTask(callable, listenerExecutor); init(); } @Override void collectOneValue(int index, @CheckForNull Object returnValue) {} @Override void handleAllCompleted() { CombinedFutureInterruptibleTask<?> localTask = task; if (localTask != null) { localTask.execute(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 6.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CombinedFuture.java
Callable<V> callable) { super(futures, allMustSucceed, false); this.task = new CallableInterruptibleTask(callable, listenerExecutor); init(); } @Override void collectOneValue(int index, @CheckForNull Object returnValue) {} @Override void handleAllCompleted() { CombinedFutureInterruptibleTask<?> localTask = task; if (localTask != null) { localTask.execute(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 6.8K bytes - Viewed (0)