/guava/android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
future.addListener ( listener, directExecutor ( ) ) ;
} } else { ImmutableCollection<? extends Future<? extends InputT>> localFutures = collectsValues ? futures : null; Runnable listener = () -> decrementCountAndMaybeComplete(localFutures); for (ListenableFuture<? extends InputT> future : futures) { <extra_id_0> } } } private void handleException(Throwable throwable) { checkNotNull(throwable); if (allMustSucceed) {