4- ? ? ?  B  ? ? B C ? ? ?  d d  z z    B  ?   # ? ? ? ? ? ? ? 2 ? ? ?  ? C 5 ReleaseResourcesReason InnerClassesloggerLjava/util/logging/Logger;futures/Lcom/google/common/collect/ImmutableCollection; SignatureqLcom/google/common/collect/ImmutableCollection<+Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;>;RuntimeVisibleTypeAnnotations5Lorg/checkerframework/checker/nullness/qual/Nullable;allMustSucceedZcollectsValues4(Lcom/google/common/collect/ImmutableCollection;ZZ)VCodeLineNumberTableLocalVariableTablethis3Lcom/google/common/util/concurrent/AggregateFuture;LocalVariableTypeTableFLcom/google/common/util/concurrent/AggregateFuture;v(Lcom/google/common/collect/ImmutableCollection<+Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;>;ZZ)V afterDone()VfutureLjava/util/concurrent/Future;wasInterrupted localFutures Ljava/util/concurrent/Future<*>;RLcom/google/common/collect/ImmutableCollection<+Ljava/util/concurrent/Future<*>;>; StackMapTablependingToString()Ljava/lang/String;initindexI4Lcom/google/common/util/concurrent/ListenableFuture;ilistenerLjava/lang/Runnable;?Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;ZLcom/google/common/collect/ImmutableCollection<+Ljava/util/concurrent/Future<+TInputT;>;>;handleException(Ljava/lang/Throwable;)VfirstTimeSeeingThisExceptioncompletedWithFailure throwableLjava/lang/Throwable;logmessageLjava/lang/String;addInitialException(Ljava/util/Set;)VseenLjava/util/Set;&Ljava/util/Set;)(Ljava/util/Set;)V"collectValueFromNonCancelledFuture!(ILjava/util/concurrent/Future;)Ve)Ljava/util/concurrent/ExecutionException;t(Ljava/util/concurrent/Future<+TInputT;>;,(ILjava/util/concurrent/Future<+TInputT;>;)VdecrementCountAndMaybeComplete2(Lcom/google/common/collect/ImmutableCollection;)V"futuresIfNeedToCollectAtCompletion newRemaining](Lcom/google/common/collect/ImmutableCollection<+Ljava/util/concurrent/Future<+TInputT;>;>;)VprocessCompletedreleaseResourcesM(Lcom/google/common/util/concurrent/AggregateFuture$ReleaseResourcesReason;)VreasonJLcom/google/common/util/concurrent/AggregateFuture$ReleaseResourcesReason;RuntimeInvisibleAnnotations/Lcom/google/errorprone/annotations/ForOverride;DLcom/google/errorprone/annotations/OverridingMethodsMustInvokeSuper;collectOneValue(ILjava/lang/Object;)V (ITInputT;)VhandleAllCompletedaddCausalChain'(Ljava/util/Set;Ljava/lang/Throwable;)Z firstTimeSeen>(Ljava/util/Set;Ljava/lang/Throwable;)Z access$002(Lcom/google/common/util/concurrent/AggregateFuture;Lcom/google/common/collect/ImmutableCollection;)Lcom/google/common/collect/ImmutableCollection;x0x1 access$100T(Lcom/google/common/util/concurrent/AggregateFuture;ILjava/util/concurrent/Future;)Vx2 access$200e(Lcom/google/common/util/concurrent/AggregateFuture;Lcom/google/common/collect/ImmutableCollection;)VxLcom/google/common/util/concurrent/AggregateFutureState; SourceFileAggregateFuture.java-Lcom/google/common/annotations/GwtCompatible; HI Q -com/google/common/collect/ImmutableCollection NO PO [\ _  java/util/concurrent/Future   java/lang/StringBuilderfutures=   f ef  \2com/google/common/util/concurrent/ListenableFuture3com/google/common/util/concurrent/AggregateFuture$1 Q   3com/google/common/util/concurrent/AggregateFuture$2 Q   wrjava/lang/ErrorInput Future failed with ErrorHGot more than one input Future failure. Logging failures after the first FG  w   'java/util/concurrent/ExecutionException   qrjava/lang/Throwable !Less than 0 remaining futures "# $\ %& '(1com/google/common/util/concurrent/AggregateFuture) *f +,6com/google/common/util/concurrent/AggregateFutureStateHcom/google/common/util/concurrent/AggregateFuture$ReleaseResourcesReasonjava/util/Iteratorjava/lang/Runnablejava/lang/Stringsize()I(I)V$com/google/common/base/Preconditions checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object;OUTPUT_FUTURE_DONE isCancelled()Ziterator2()Lcom/google/common/collect/UnmodifiableIterator;hasNextnext()Ljava/lang/Object;cancel(Z)ZvalueOf&(Ljava/lang/Object;)Ljava/lang/String;lengthappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;toStringisEmptyk(Lcom/google/common/util/concurrent/AggregateFuture;Lcom/google/common/util/concurrent/ListenableFuture;I)V/com/google/common/util/concurrent/MoreExecutorsdirectExecutor!()Ljava/util/concurrent/Executor; addListener6(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V setException(Ljava/lang/Throwable;)ZgetOrInitSeenExceptions()Ljava/util/Set;java/util/logging/LevelSEVERELjava/util/logging/Level;java/util/logging/LoggerC(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)VtryInternalFastPathGetFailure()Ljava/lang/Throwable;)com/google/common/util/concurrent/FuturesgetDone1(Ljava/util/concurrent/Future;)Ljava/lang/Object;getCausedecrementRemainingAndGet checkState(ZLjava/lang/Object;)VclearSeenExceptionsALL_INPUT_FUTURES_PROCESSED java/util/Setadd(Ljava/lang/Object;)Zjava/lang/ClassgetName getLogger.(Ljava/lang/String;)Ljava/util/logging/Logger; ?BFGHIJKLMNOPOQRS*+*+** T@ABCDU*VWHINOPOXVYHKJZ[\S L* *L* * +~-*=+N--:WT& HJ KM!N&O?PHQKWU*? ]^&%_OLVW C`IX ? ]aLVY C`bc)?? defS2*L+'+M,`Z_,*T[\ ]-_U2VW-`IX2VY-`bc-g\S***@<*M,*,N6-Y*- !"ӧG* *L#Y*+$M*N--:,!"TJk lms}~39EHMPScmUH9hi3]j8ki ]jc4`Im*lmVWX*3]n ]nc4`oVYc"d/ @pd!qrS4+W**+%=*&+'>+(+)+(T.  #'(/3U* sOtO4VW4uvX 4VYc( wrSl*)*+L,-+*.T Uuv xyc Az{|S{+W* +*/'=T UVW}~XVY}cJS*,01N*-34 N*-4 2 5T" U4 vVWhi]^XVY]c L2K5JS*6=78*+9T U VWIiXVYoc  @ JL MSF+5=+N-%-:: **;**< T. )036:>"E#U*]^0kiFVWFIX ]FVYFoc d$JL MSY +W*T29 :U VW X  VY JL M\ S+*+==+>LTKL MTKWU  O}~vX }cJS;*+ZT*UWISE*,T*U Wi^S:*+T*UWI\S$ ?@A,T+JEC?D@#