class com.netflix.hystrix.HystrixObservableCollapser$1$3 implements rx.functions.Action0
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.netflix.hystrix.HystrixObservableCollapser$1$3
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 java.util.Map val$requestsByKey;
descriptor: Ljava/util/Map;
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, java.util.Map, java.util.Set);
descriptor: (Lcom/netflix/hystrix/HystrixObservableCollapser$1;Ljava/util/Map;Ljava/util/Set;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 0: aload 0
aload 1
putfield com.netflix.hystrix.HystrixObservableCollapser$1$3.this$1:Lcom/netflix/hystrix/HystrixObservableCollapser$1;
aload 0
aload 2
putfield com.netflix.hystrix.HystrixObservableCollapser$1$3.val$requestsByKey:Ljava/util/Map;
aload 0
aload 3
putfield com.netflix.hystrix.HystrixObservableCollapser$1$3.val$seenKeys:Ljava/util/Set;
aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/HystrixObservableCollapser$1$3;
MethodParameters:
Name Flags
this$0 final
val$requestsByKey final
val$seenKeys final
public void call();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.HystrixObservableCollapser$1$3.val$requestsByKey:Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 2
goto 10
StackMap locals: com.netflix.hystrix.HystrixObservableCollapser$1$3 top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 1
start local 1 2: aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
astore 3
start local 3 3: aload 1
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast com.netflix.hystrix.HystrixCollapser$CollapsedRequest
astore 4
start local 4 4: aload 0
getfield com.netflix.hystrix.HystrixObservableCollapser$1$3.val$seenKeys:Ljava/util/Set;
aload 3
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifne 9
5: aload 0
getfield com.netflix.hystrix.HystrixObservableCollapser$1$3.this$1:Lcom/netflix/hystrix/HystrixObservableCollapser$1;
invokestatic com.netflix.hystrix.HystrixObservableCollapser$1.access$0:(Lcom/netflix/hystrix/HystrixObservableCollapser$1;)Lcom/netflix/hystrix/HystrixObservableCollapser;
aload 4
invokevirtual com.netflix.hystrix.HystrixObservableCollapser.onMissingResponse:(Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest;)V
6: goto 9
StackMap locals: com.netflix.hystrix.HystrixObservableCollapser$1$3 java.util.Map$Entry java.util.Iterator java.lang.Object com.netflix.hystrix.HystrixCollapser$CollapsedRequest
StackMap stack: java.lang.Throwable
7: astore 5
start local 5 8: aload 4
new java.lang.RuntimeException
dup
ldc "Error in HystrixObservableCollapser.onMissingResponse handler"
aload 5
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
invokeinterface com.netflix.hystrix.HystrixCollapser$CollapsedRequest.setException:(Ljava/lang/Exception;)V
end local 5 9: StackMap locals:
StackMap stack:
aload 4
invokeinterface com.netflix.hystrix.HystrixCollapser$CollapsedRequest.setComplete:()V
end local 4 end local 3 end local 1 10: StackMap locals: com.netflix.hystrix.HystrixObservableCollapser$1$3 top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
11: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/netflix/hystrix/HystrixObservableCollapser$1$3;
2 10 1 entry Ljava/util/Map$Entry<TK;Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;
3 10 3 key TK;
4 10 4 collapsedReq Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;
8 9 5 ex Ljava/lang/Throwable;
Exception table:
from to target type
5 6 7 Class java.lang.Throwable
}
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$3
public abstract Entry = java.util.Map$Entry of java.util.Map