class com.netflix.hystrix.HystrixObservableCollapser$1$1 implements rx.functions.Action1<BatchReturnType>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: com.netflix.hystrix.HystrixObservableCollapser$1$1
  super_class: java.lang.Object
{
  final com.netflix.hystrix.HystrixObservableCollapser$1 this$1;
    descriptor: Lcom/netflix/hystrix/HystrixObservableCollapser$1;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private final rx.functions.Func1 val$batchResponseKeySelector;
    descriptor: Lrx/functions/Func1;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final java.util.Map val$requestsByKey;
    descriptor: Ljava/util/Map;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final rx.functions.Func1 val$mapBatchTypeToResponseType;
    descriptor: Lrx/functions/Func1;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final java.util.Set val$seenKeys;
    descriptor: Ljava/util/Set;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  void <init>(com.netflix.hystrix.HystrixObservableCollapser$1, rx.functions.Func1, java.util.Map, rx.functions.Func1, java.util.Set);
    descriptor: (Lcom/netflix/hystrix/HystrixObservableCollapser$1;Lrx/functions/Func1;Ljava/util/Map;Lrx/functions/Func1;Ljava/util/Set;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=6, args_size=6
        start local 0 // com.netflix.hystrix.HystrixObservableCollapser$1$1 this
         0: .line 184
            aload 0 /* this */
            aload 1
            putfield com.netflix.hystrix.HystrixObservableCollapser$1$1.this$1:Lcom/netflix/hystrix/HystrixObservableCollapser$1;
            aload 0 /* this */
            aload 2
            putfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$batchResponseKeySelector:Lrx/functions/Func1;
            aload 0 /* this */
            aload 3
            putfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$requestsByKey:Ljava/util/Map;
            aload 0 /* this */
            aload 4
            putfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$mapBatchTypeToResponseType:Lrx/functions/Func1;
            aload 0 /* this */
            aload 5
            putfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$seenKeys:Ljava/util/Set;
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // com.netflix.hystrix.HystrixObservableCollapser$1$1 this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/netflix/hystrix/HystrixObservableCollapser$1$1;
    MethodParameters:
                                Name  Flags
      this$0                          final
      val$batchResponseKeySelector    final
      val$requestsByKey               final
      val$mapBatchTypeToResponseType  final
      val$seenKeys                    final

  public void call();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // com.netflix.hystrix.HystrixObservableCollapser$1$1 this
        start local 1 // java.lang.Object batchReturnType
         0: .line 188
            aload 0 /* this */
            getfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$batchResponseKeySelector:Lrx/functions/Func1;
            aload 1 /* batchReturnType */
            invokeinterface rx.functions.Func1.call:(Ljava/lang/Object;)Ljava/lang/Object;
            astore 2 /* responseKey */
        start local 2 // java.lang.Object responseKey
         1: .line 189
            aload 0 /* this */
            getfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$requestsByKey:Ljava/util/Map;
            aload 2 /* responseKey */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.netflix.hystrix.HystrixCollapser$CollapsedRequest
            astore 3 /* requestForResponse */
        start local 3 // com.netflix.hystrix.HystrixCollapser$CollapsedRequest requestForResponse
         2: .line 190
            aload 3 /* requestForResponse */
            ifnull 6
         3: .line 191
            aload 3 /* requestForResponse */
            aload 0 /* this */
            getfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$mapBatchTypeToResponseType:Lrx/functions/Func1;
            aload 1 /* batchReturnType */
            invokeinterface rx.functions.Func1.call:(Ljava/lang/Object;)Ljava/lang/Object;
            invokeinterface com.netflix.hystrix.HystrixCollapser$CollapsedRequest.emitResponse:(Ljava/lang/Object;)V
         4: .line 193
            aload 0 /* this */
            getfield com.netflix.hystrix.HystrixObservableCollapser$1$1.val$seenKeys:Ljava/util/Set;
            aload 2 /* responseKey */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         5: .line 194
            goto 10
         6: .line 195
      StackMap locals: java.lang.Object com.netflix.hystrix.HystrixCollapser$CollapsedRequest
      StackMap stack:
            getstatic com.netflix.hystrix.HystrixObservableCollapser.logger:Lorg/slf4j/Logger;
            ldc "Batch Response contained a response key not in request batch : {}"
            aload 2 /* responseKey */
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
        end local 3 // com.netflix.hystrix.HystrixCollapser$CollapsedRequest requestForResponse
        end local 2 // java.lang.Object responseKey
         7: .line 197
            goto 10
      StackMap locals: com.netflix.hystrix.HystrixObservableCollapser$1$1 java.lang.Object
      StackMap stack: java.lang.Throwable
         8: astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         9: .line 198
            getstatic com.netflix.hystrix.HystrixObservableCollapser.logger:Lorg/slf4j/Logger;
            ldc "Uncaught error during demultiplexing of BatchResponse"
            aload 2 /* ex */
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 2 // java.lang.Throwable ex
        10: .line 200
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object batchReturnType
        end local 0 // com.netflix.hystrix.HystrixObservableCollapser$1$1 this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   11     0                this  Lcom/netflix/hystrix/HystrixObservableCollapser$1$1;
            0   11     1     batchReturnType  TBatchReturnType;
            1    7     2         responseKey  TK;
            2    7     3  requestForResponse  Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;
            9   10     2                  ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     7       8  Class java.lang.Throwable
    Signature: (TBatchReturnType;)V
    MethodParameters:
                 Name  Flags
      batchReturnType  
}
Signature: Ljava/lang/Object;Lrx/functions/Action1<TBatchReturnType;>;
SourceFile: "HystrixObservableCollapser.java"
EnclosingMethod: com.netflix.hystrix.HystrixObservableCollapser$1.mapResponseToRequests:(Lrx/Observable;Ljava/util/Collection;)Lrx/Observable;
NestHost: com.netflix.hystrix.HystrixObservableCollapser
InnerClasses:
  public abstract CollapsedRequest = com.netflix.hystrix.HystrixCollapser$CollapsedRequest of com.netflix.hystrix.HystrixCollapser
  com.netflix.hystrix.HystrixObservableCollapser$1
  com.netflix.hystrix.HystrixObservableCollapser$1$1