/guava/guava/src/com/google/common/util/concurrent/ClosingFuture.java
return allMustSucceed ? Futures.whenAllSucceed( directExecutor( ) ) : Futures.whenAllComplete( inputFutures( ) ) ;
return allMustSucceed ? Futures.whenAllSucceed ( inputFutures ( ) ) : Futures.whenAllComplete ( inputFutures ( ) ) ;
ClosingFuture<V> derived = new ClosingFuture<>(futureCombiner().callAsync(asyncCallable, executor)); derived.closeables.add(closeables, directExecutor()); return derived; } private FutureCombiner<@Nullable Object> futureCombiner() { <extra_id_0> } private ImmutableList<FluentFuture<?>> inputFutures() { return FluentIterable.from(inputs) .<FluentFuture<?>>transform(future -> future.future) .toList(); }