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