https://github.com/google/guava/guava: Guava is a suite of core and expanded libraries that include utility classes, google's collections, io classes, and much much more. 
abstract class com.google.common.util.concurrent.AggregateFuture$RunningState extends com.google.common.util.concurrent.AggregateFutureState implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
  this_class: com.google.common.util.concurrent.AggregateFuture$RunningState
  super_class: com.google.common.util.concurrent.AggregateFutureState
{
  private com.google.common.collect.ImmutableCollection<? extends com.google.common.util.concurrent.ListenableFuture<? extends InputT>> futures;
    descriptor: Lcom/google/common/collect/ImmutableCollection;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lcom/google/common/collect/ImmutableCollection<+Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;>;

  private final boolean allMustSucceed;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final boolean collectsValues;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final com.google.common.util.concurrent.AggregateFuture this$0;
    descriptor: Lcom/google/common/util/concurrent/AggregateFuture;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(com.google.common.collect.ImmutableCollection<? extends com.google.common.util.concurrent.ListenableFuture<? extends InputT>>, boolean, );
    descriptor: (Lcom/google/common/util/concurrent/AggregateFuture;Lcom/google/common/collect/ImmutableCollection;ZZ)V
    flags: (0x0000) 
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
        start local 2 // com.google.common.collect.ImmutableCollection futures
        start local 3 // boolean allMustSucceed
        start local 4 // boolean collectsValues
         0: .line 100
            aload 0 /* this */
            aload 1
            putfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
         1: .line 101
            aload 0 /* this */
            aload 2 /* futures */
            invokevirtual com.google.common.collect.ImmutableCollection.size:()I
            invokespecial com.google.common.util.concurrent.AggregateFutureState.<init>:(I)V
         2: .line 102
            aload 0 /* this */
            aload 2 /* futures */
            invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.google.common.collect.ImmutableCollection
            putfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
         3: .line 103
            aload 0 /* this */
            iload 3 /* allMustSucceed */
            putfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
         4: .line 104
            aload 0 /* this */
            iload 4 /* collectsValues */
            putfield com.google.common.util.concurrent.AggregateFuture$RunningState.collectsValues:Z
         5: .line 105
            return
        end local 4 // boolean collectsValues
        end local 3 // boolean allMustSucceed
        end local 2 // com.google.common.collect.ImmutableCollection futures
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    6     0            this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            0    6     2         futures  Lcom/google/common/collect/ImmutableCollection<+Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;>;
            0    6     3  allMustSucceed  Z
            0    6     4  collectsValues  Z
    Signature: (Lcom/google/common/collect/ImmutableCollection<+Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;>;ZZ)V
    MethodParameters:
                Name  Flags
      this$0          final
      futures         
      allMustSucceed  
      collectsValues  

  public final void run();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 110
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.decrementCountAndMaybeComplete:()V
         1: .line 111
            return
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;

  private void init();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=5, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 121
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
            invokevirtual com.google.common.collect.ImmutableCollection.isEmpty:()Z
            ifeq 3
         1: .line 122
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.handleAllCompleted:()V
         2: .line 123
            return
         3: .line 129
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            ifeq 14
         4: .line 139
            iconst_0
            istore 1 /* i */
        start local 1 // int i
         5: .line 140
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
            invokevirtual com.google.common.collect.ImmutableCollection.iterator:()Ljava/util/Iterator;
            astore 3
            goto 12
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState int top java.util.Iterator
      StackMap stack:
         6: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.google.common.util.concurrent.ListenableFuture
            astore 2 /* listenable */
        start local 2 // com.google.common.util.concurrent.ListenableFuture listenable
         7: .line 141
            iload 1 /* i */
            iinc 1 /* i */ 1
            istore 4 /* index */
        start local 4 // int index
         8: .line 142
            aload 2 /* listenable */
         9: .line 143
            new com.google.common.util.concurrent.AggregateFuture$RunningState$1
            dup
            aload 0 /* this */
            iload 4 /* index */
            aload 2 /* listenable */
            invokespecial com.google.common.util.concurrent.AggregateFuture$RunningState$1.<init>:(Lcom/google/common/util/concurrent/AggregateFuture$RunningState;ILcom/google/common/util/concurrent/ListenableFuture;)V
        10: .line 153
            invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
        11: .line 142
            invokeinterface com.google.common.util.concurrent.ListenableFuture.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
        end local 4 // int index
        end local 2 // com.google.common.util.concurrent.ListenableFuture listenable
        12: .line 140
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
        end local 1 // int i
        13: .line 155
            goto 18
        14: .line 158
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState
      StackMap stack:
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
            invokevirtual com.google.common.collect.ImmutableCollection.iterator:()Ljava/util/Iterator;
            astore 2
            goto 17
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState top java.util.Iterator
      StackMap stack:
        15: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.google.common.util.concurrent.ListenableFuture
            astore 1 /* listenable */
        start local 1 // com.google.common.util.concurrent.ListenableFuture listenable
        16: .line 159
            aload 1 /* listenable */
            aload 0 /* this */
            invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
            invokeinterface com.google.common.util.concurrent.ListenableFuture.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
        end local 1 // com.google.common.util.concurrent.ListenableFuture listenable
        17: .line 158
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 15
        18: .line 162
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState
      StackMap stack:
            return
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   19     0        this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            5   13     1           i  I
            7   12     2  listenable  Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;
            8   12     4       index  I
           16   17     1  listenable  Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;

  private void handleException(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
        start local 1 // java.lang.Throwable throwable
         0: .line 171
            aload 1 /* throwable */
            invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 173
            iconst_0
            istore 2 /* completedWithFailure */
        start local 2 // boolean completedWithFailure
         2: .line 174
            iconst_1
            istore 3 /* firstTimeSeeingThisException */
        start local 3 // boolean firstTimeSeeingThisException
         3: .line 175
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            ifeq 9
         4: .line 178
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            aload 1 /* throwable */
            invokevirtual com.google.common.util.concurrent.AggregateFuture.setException:(Ljava/lang/Throwable;)Z
            istore 2 /* completedWithFailure */
         5: .line 179
            iload 2 /* completedWithFailure */
            ifeq 8
         6: .line 180
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.releaseResourcesAfterFailure:()V
         7: .line 181
            goto 9
         8: .line 184
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.getOrInitSeenExceptions:()Ljava/util/Set;
            aload 1 /* throwable */
            invokestatic com.google.common.util.concurrent.AggregateFuture.addCausalChain:(Ljava/util/Set;Ljava/lang/Throwable;)Z
            istore 3 /* firstTimeSeeingThisException */
         9: .line 189
      StackMap locals:
      StackMap stack:
            aload 1 /* throwable */
            instanceof java.lang.Error
        10: .line 190
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            iload 2 /* completedWithFailure */
            ifeq 11
            iconst_0
            goto 12
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState java.lang.Throwable int int
      StackMap stack: int int
        11: iconst_1
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState java.lang.Throwable int int
      StackMap stack: int int int
        12: iand
            iload 3 /* firstTimeSeeingThisException */
            iand
            ior
            ifeq 18
        13: .line 192
            aload 1 /* throwable */
            instanceof java.lang.Error
            ifeq 15
        14: .line 193
            ldc "Input Future failed with Error"
            goto 16
        15: .line 194
      StackMap locals:
      StackMap stack:
            ldc "Got more than one input Future failure. Logging failures after the first"
        16: .line 191
      StackMap locals:
      StackMap stack: java.lang.String
            astore 4 /* message */
        start local 4 // java.lang.String message
        17: .line 195
            getstatic com.google.common.util.concurrent.AggregateFuture.logger:Ljava/util/logging/Logger;
            getstatic java.util.logging.Level.SEVERE:Ljava/util/logging/Level;
            aload 4 /* message */
            aload 1 /* throwable */
            invokevirtual java.util.logging.Logger.log:(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 4 // java.lang.String message
        18: .line 197
      StackMap locals:
      StackMap stack:
            return
        end local 3 // boolean firstTimeSeeingThisException
        end local 2 // boolean completedWithFailure
        end local 1 // java.lang.Throwable throwable
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0   19     0                          this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            0   19     1                     throwable  Ljava/lang/Throwable;
            2   19     2          completedWithFailure  Z
            3   19     3  firstTimeSeeingThisException  Z
           17   18     4                       message  Ljava/lang/String;
    MethodParameters:
           Name  Flags
      throwable  

  final void addInitialException(java.util.Set<java.lang.Throwable>);
    descriptor: (Ljava/util/Set;)V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
        start local 1 // java.util.Set seen
         0: .line 201
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            invokevirtual com.google.common.util.concurrent.AggregateFuture.isCancelled:()Z
            ifne 2
         1: .line 203
            aload 1 /* seen */
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            invokevirtual com.google.common.util.concurrent.AggregateFuture.trustedGetException:()Ljava/lang/Throwable;
            invokestatic com.google.common.util.concurrent.AggregateFuture.addCausalChain:(Ljava/util/Set;Ljava/lang/Throwable;)Z
            pop
         2: .line 205
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.util.Set seen
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            0    3     1  seen  Ljava/util/Set<Ljava/lang/Throwable;>;
    Signature: (Ljava/util/Set<Ljava/lang/Throwable;>;)V
    MethodParameters:
      Name  Flags
      seen  

  private void handleOneInputDone(int, java.util.concurrent.Future<? extends InputT>);
    descriptor: (ILjava/util/concurrent/Future;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
        start local 1 // int index
        start local 2 // java.util.concurrent.Future future
         0: .line 212
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            ifne 1
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            invokevirtual com.google.common.util.concurrent.AggregateFuture.isDone:()Z
            ifeq 1
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            invokevirtual com.google.common.util.concurrent.AggregateFuture.isCancelled:()Z
            ifne 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_1
         2: .line 213
      StackMap locals:
      StackMap stack: int
            ldc "Future was done before all dependencies completed"
         3: .line 211
            invokestatic com.google.common.base.Preconditions.checkState:(ZLjava/lang/Object;)V
         4: .line 216
            aload 2 /* future */
            invokeinterface java.util.concurrent.Future.isDone:()Z
            ldc "Tried to set value from future which is not done"
            invokestatic com.google.common.base.Preconditions.checkState:(ZLjava/lang/Object;)V
         5: .line 217
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            ifeq 14
         6: .line 218
            aload 2 /* future */
            invokeinterface java.util.concurrent.Future.isCancelled:()Z
            ifeq 10
         7: .line 221
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            aconst_null
            putfield com.google.common.util.concurrent.AggregateFuture.runningState:Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
         8: .line 222
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.this$0:Lcom/google/common/util/concurrent/AggregateFuture;
            iconst_0
            invokevirtual com.google.common.util.concurrent.AggregateFuture.cancel:(Z)Z
            pop
         9: .line 223
            goto 22
        10: .line 225
      StackMap locals:
      StackMap stack:
            aload 2 /* future */
            invokestatic com.google.common.util.concurrent.Futures.getDone:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
            astore 3 /* result */
        start local 3 // java.lang.Object result
        11: .line 226
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.collectsValues:Z
            ifeq 22
        12: .line 227
            aload 0 /* this */
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            iload 1 /* index */
            aload 3 /* result */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.collectOneValue:(ZILjava/lang/Object;)V
        end local 3 // java.lang.Object result
        13: .line 230
            goto 22
      StackMap locals:
      StackMap stack:
        14: aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.collectsValues:Z
            ifeq 22
            aload 2 /* future */
            invokeinterface java.util.concurrent.Future.isCancelled:()Z
            ifne 22
        15: .line 231
            aload 0 /* this */
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            iload 1 /* index */
            aload 2 /* future */
            invokestatic com.google.common.util.concurrent.Futures.getDone:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.collectOneValue:(ZILjava/lang/Object;)V
        16: .line 233
            goto 22
      StackMap locals:
      StackMap stack: java.util.concurrent.ExecutionException
        17: astore 3 /* e */
        start local 3 // java.util.concurrent.ExecutionException e
        18: .line 234
            aload 0 /* this */
            aload 3 /* e */
            invokevirtual java.util.concurrent.ExecutionException.getCause:()Ljava/lang/Throwable;
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.handleException:(Ljava/lang/Throwable;)V
        end local 3 // java.util.concurrent.ExecutionException e
        19: goto 22
        20: .line 235
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 3 /* t */
        start local 3 // java.lang.Throwable t
        21: .line 236
            aload 0 /* this */
            aload 3 /* t */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.handleException:(Ljava/lang/Throwable;)V
        end local 3 // java.lang.Throwable t
        22: .line 238
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.util.concurrent.Future future
        end local 1 // int index
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   23     0    this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            0   23     1   index  I
            0   23     2  future  Ljava/util/concurrent/Future<+TInputT;>;
           11   13     3  result  TInputT;
           18   19     3       e  Ljava/util/concurrent/ExecutionException;
           21   22     3       t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           4    16      17  Class java.util.concurrent.ExecutionException
           4    16      20  Class java.lang.Throwable
    Signature: (ILjava/util/concurrent/Future<+TInputT;>;)V
    MethodParameters:
        Name  Flags
      index   
      future  

  private void decrementCountAndMaybeComplete();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 241
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.decrementRemainingAndGet:()I
            istore 1 /* newRemaining */
        start local 1 // int newRemaining
         1: .line 242
            iload 1 /* newRemaining */
            iflt 2
            iconst_1
            goto 3
      StackMap locals: int
      StackMap stack:
         2: iconst_0
      StackMap locals:
      StackMap stack: int
         3: ldc "Less than 0 remaining futures"
            invokestatic com.google.common.base.Preconditions.checkState:(ZLjava/lang/Object;)V
         4: .line 243
            iload 1 /* newRemaining */
            ifne 6
         5: .line 244
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.processCompleted:()V
         6: .line 246
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int newRemaining
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            1    7     1  newRemaining  I

  private void processCompleted();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 251
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.collectsValues:Z
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.allMustSucceed:Z
            ifeq 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack: int
         1: iconst_1
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState
      StackMap stack: int int
         2: iand
            ifeq 8
         3: .line 252
            iconst_0
            istore 1 /* i */
        start local 1 // int i
         4: .line 253
            aload 0 /* this */
            getfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
            invokevirtual com.google.common.collect.ImmutableCollection.iterator:()Ljava/util/Iterator;
            astore 3
            goto 7
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState int top java.util.Iterator
      StackMap stack:
         5: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.google.common.util.concurrent.ListenableFuture
            astore 2 /* listenable */
        start local 2 // com.google.common.util.concurrent.ListenableFuture listenable
         6: .line 254
            aload 0 /* this */
            iload 1 /* i */
            iinc 1 /* i */ 1
            aload 2 /* listenable */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.handleOneInputDone:(ILjava/util/concurrent/Future;)V
        end local 2 // com.google.common.util.concurrent.ListenableFuture listenable
         7: .line 253
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        end local 1 // int i
         8: .line 257
      StackMap locals: com.google.common.util.concurrent.AggregateFuture$RunningState
      StackMap stack:
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.AggregateFuture$RunningState.handleAllCompleted:()V
         9: .line 258
            return
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0        this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
            4    8     1           i  I
            6    7     2  listenable  Lcom/google/common/util/concurrent/ListenableFuture<+TInputT;>;

  void releaseResourcesAfterFailure();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 272
            aload 0 /* this */
            aconst_null
            putfield com.google.common.util.concurrent.AggregateFuture$RunningState.futures:Lcom/google/common/collect/ImmutableCollection;
         1: .line 273
            return
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
    RuntimeInvisibleAnnotations: 
      com.google.errorprone.annotations.ForOverride()
      com.google.errorprone.annotations.OverridingMethodsMustInvokeSuper()

  abstract void collectOneValue(boolean, int, );
    descriptor: (ZILjava/lang/Object;)V
    flags: (0x0400) ACC_ABSTRACT
    Signature: (ZITInputT;)V
    RuntimeVisibleTypeAnnotations: 
      METHOD_FORMAL_PARAMETER
        org.checkerframework.checker.nullness.qual.Nullable()
    MethodParameters:
                Name  Flags
      allMustSucceed  
      index           
      returnValue     

  abstract void handleAllCompleted();
    descriptor: ()V
    flags: (0x0400) ACC_ABSTRACT

  void interruptTask();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
         0: .line 285
            return
        end local 0 // com.google.common.util.concurrent.AggregateFuture$RunningState this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/google/common/util/concurrent/AggregateFuture$RunningState;
}
SourceFile: "AggregateFuture.java"
NestHost: com.google.common.util.concurrent.AggregateFuture
InnerClasses:
  abstract RunningState = com.google.common.util.concurrent.AggregateFuture$RunningState of com.google.common.util.concurrent.AggregateFuture
  com.google.common.util.concurrent.AggregateFuture$RunningState$1