class com.netflix.hystrix.HystrixCollapser$1 implements com.netflix.hystrix.collapser.HystrixCollapserBridge<BatchReturnType, ResponseType, RequestArgumentType>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.netflix.hystrix.HystrixCollapser$1
super_class: java.lang.Object
{
final com.netflix.hystrix.HystrixCollapser this$0;
descriptor: Lcom/netflix/hystrix/HystrixCollapser;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private final com.netflix.hystrix.HystrixCollapser val$self;
descriptor: Lcom/netflix/hystrix/HystrixCollapser;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(com.netflix.hystrix.HystrixCollapser, com.netflix.hystrix.HystrixCollapser);
descriptor: (Lcom/netflix/hystrix/HystrixCollapser;Lcom/netflix/hystrix/HystrixCollapser;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 0: aload 0
aload 1
putfield com.netflix.hystrix.HystrixCollapser$1.this$0:Lcom/netflix/hystrix/HystrixCollapser;
aload 0
aload 2
putfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
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/HystrixCollapser$1;
MethodParameters:
Name Flags
this$0 final
val$self final
public java.util.Collection<java.util.Collection<com.netflix.hystrix.HystrixCollapser$CollapsedRequest<ResponseType, RequestArgumentType>>> shardRequests(java.util.Collection<com.netflix.hystrix.HystrixCollapser$CollapsedRequest<ResponseType, RequestArgumentType>>);
descriptor: (Ljava/util/Collection;)Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
aload 1
invokevirtual com.netflix.hystrix.HystrixCollapser.shardRequests:(Ljava/util/Collection;)Ljava/util/Collection;
astore 2
start local 2 1: aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
getfield com.netflix.hystrix.HystrixCollapser.metrics:Lcom/netflix/hystrix/HystrixCollapserMetrics;
aload 2
invokeinterface java.util.Collection.size:()I
invokevirtual com.netflix.hystrix.HystrixCollapserMetrics.markShards:(I)V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/netflix/hystrix/HystrixCollapser$1;
0 3 1 requests Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;
1 3 2 shards Ljava/util/Collection<Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;>;
Signature: (Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;)Ljava/util/Collection<Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;>;
MethodParameters:
Name Flags
requests
public rx.Observable<BatchReturnType> createObservableCommand(java.util.Collection<com.netflix.hystrix.HystrixCollapser$CollapsedRequest<ResponseType, RequestArgumentType>>);
descriptor: (Ljava/util/Collection;)Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
aload 1
invokevirtual com.netflix.hystrix.HystrixCollapser.createCommand:(Ljava/util/Collection;)Lcom/netflix/hystrix/HystrixCommand;
astore 2
start local 2 1: aload 2
aload 0
invokevirtual com.netflix.hystrix.HystrixCollapser$1.getCollapserKey:()Lcom/netflix/hystrix/HystrixCollapserKey;
aload 1
invokeinterface java.util.Collection.size:()I
invokevirtual com.netflix.hystrix.HystrixCommand.markAsCollapsedCommand:(Lcom/netflix/hystrix/HystrixCollapserKey;I)V
2: aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
getfield com.netflix.hystrix.HystrixCollapser.metrics:Lcom/netflix/hystrix/HystrixCollapserMetrics;
aload 1
invokeinterface java.util.Collection.size:()I
invokevirtual com.netflix.hystrix.HystrixCollapserMetrics.markBatch:(I)V
3: aload 2
invokevirtual com.netflix.hystrix.HystrixCommand.toObservable:()Lrx/Observable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/netflix/hystrix/HystrixCollapser$1;
0 4 1 requests Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;
1 4 2 command Lcom/netflix/hystrix/HystrixCommand<TBatchReturnType;>;
Signature: (Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;)Lrx/Observable<TBatchReturnType;>;
MethodParameters:
Name Flags
requests
public rx.Observable<java.lang.Void> mapResponseToRequests(rx.Observable<BatchReturnType>, java.util.Collection<com.netflix.hystrix.HystrixCollapser$CollapsedRequest<ResponseType, RequestArgumentType>>);
descriptor: (Lrx/Observable;Ljava/util/Collection;)Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokevirtual rx.Observable.single:()Lrx/Observable;
new com.netflix.hystrix.HystrixCollapser$1$1
dup
aload 0
aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
aload 2
invokespecial com.netflix.hystrix.HystrixCollapser$1$1.<init>:(Lcom/netflix/hystrix/HystrixCollapser$1;Lcom/netflix/hystrix/HystrixCollapser;Ljava/util/Collection;)V
invokevirtual rx.Observable.doOnNext:(Lrx/functions/Action1;)Lrx/Observable;
1: invokevirtual rx.Observable.ignoreElements:()Lrx/Observable;
ldc Ljava/lang/Void;
invokevirtual rx.Observable.cast:(Ljava/lang/Class;)Lrx/Observable;
2: areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/netflix/hystrix/HystrixCollapser$1;
0 3 1 batchResponse Lrx/Observable<TBatchReturnType;>;
0 3 2 requests Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;
Signature: (Lrx/Observable<TBatchReturnType;>;Ljava/util/Collection<Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;>;)Lrx/Observable<Ljava/lang/Void;>;
MethodParameters:
Name Flags
batchResponse
requests final
public com.netflix.hystrix.HystrixCollapserKey getCollapserKey();
descriptor: ()Lcom/netflix/hystrix/HystrixCollapserKey;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.HystrixCollapser$1.val$self:Lcom/netflix/hystrix/HystrixCollapser;
invokevirtual com.netflix.hystrix.HystrixCollapser.getCollapserKey:()Lcom/netflix/hystrix/HystrixCollapserKey;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/HystrixCollapser$1;
}
Signature: Ljava/lang/Object;Lcom/netflix/hystrix/collapser/HystrixCollapserBridge<TBatchReturnType;TResponseType;TRequestArgumentType;>;
SourceFile: "HystrixCollapser.java"
EnclosingMethod: com.netflix.hystrix.HystrixCollapser.<init>:(Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/HystrixCollapser$Scope;Lcom/netflix/hystrix/collapser/CollapserTimer;Lcom/netflix/hystrix/HystrixCollapserProperties$Setter;Lcom/netflix/hystrix/HystrixCollapserMetrics;)V
NestHost: com.netflix.hystrix.HystrixCollapser
InnerClasses:
com.netflix.hystrix.HystrixCollapser$1
com.netflix.hystrix.HystrixCollapser$1$1
public abstract CollapsedRequest = com.netflix.hystrix.HystrixCollapser$CollapsedRequest of com.netflix.hystrix.HystrixCollapser
public final Scope = com.netflix.hystrix.HystrixCollapser$Scope of com.netflix.hystrix.HystrixCollapser
public Setter = com.netflix.hystrix.HystrixCollapserProperties$Setter of com.netflix.hystrix.HystrixCollapserProperties