class com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3 extends rx.Subscriber<R>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3
super_class: rx.Subscriber
{
final com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator this$1;
descriptor: Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private final java.lang.ref.Reference val$tl;
descriptor: Ljava/lang/ref/Reference;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
private final rx.Subscriber val$child;
descriptor: Lrx/Subscriber;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator, java.lang.ref.Reference, rx.Subscriber);
descriptor: (Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator;Ljava/lang/ref/Reference;Lrx/Subscriber;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 0: aload 0
aload 1
putfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.this$1:Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator;
aload 0
aload 2
putfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$tl:Ljava/lang/ref/Reference;
aload 0
aload 3
putfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$child:Lrx/Subscriber;
aload 0
invokespecial rx.Subscriber.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator$3;
MethodParameters:
Name Flags
this$0 final
val$tl final
val$child final
public void onCompleted();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.isNotTimedOut:()Z
ifeq 3
1: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$tl:Ljava/lang/ref/Reference;
invokevirtual java.lang.ref.Reference.clear:()V
2: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$child:Lrx/Subscriber;
invokevirtual rx.Subscriber.onCompleted:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator$3;
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.isNotTimedOut:()Z
ifeq 3
1: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$tl:Ljava/lang/ref/Reference;
invokevirtual java.lang.ref.Reference.clear:()V
2: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$child:Lrx/Subscriber;
aload 1
invokevirtual rx.Subscriber.onError:(Ljava/lang/Throwable;)V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator$3;
0 4 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.isNotTimedOut:()Z
ifeq 2
1: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.val$child:Lrx/Subscriber;
aload 1
invokevirtual rx.Subscriber.onNext:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator$3;
0 3 1 v TR;
Signature: (TR;)V
MethodParameters:
Name Flags
v
private boolean isNotTimedOut();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.this$1:Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator;
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator.originalCommand:Lcom/netflix/hystrix/AbstractCommand;
getfield com.netflix.hystrix.AbstractCommand.isCommandTimedOut:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
getstatic com.netflix.hystrix.AbstractCommand$TimedOutStatus.COMPLETED:Lcom/netflix/hystrix/AbstractCommand$TimedOutStatus;
if_acmpeq 3
1: aload 0
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3.this$1:Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator;
getfield com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator.originalCommand:Lcom/netflix/hystrix/AbstractCommand;
getfield com.netflix.hystrix.AbstractCommand.isCommandTimedOut:Ljava/util/concurrent/atomic/AtomicReference;
getstatic com.netflix.hystrix.AbstractCommand$TimedOutStatus.NOT_EXECUTED:Lcom/netflix/hystrix/AbstractCommand$TimedOutStatus;
getstatic com.netflix.hystrix.AbstractCommand$TimedOutStatus.COMPLETED:Lcom/netflix/hystrix/AbstractCommand$TimedOutStatus;
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 3
2: iconst_0
ireturn
StackMap locals:
StackMap stack:
3: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/netflix/hystrix/AbstractCommand$HystrixObservableTimeoutOperator$3;
}
Signature: Lrx/Subscriber<TR;>;
SourceFile: "AbstractCommand.java"
EnclosingMethod: com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator.call:(Lrx/Subscriber;)Lrx/Subscriber;
NestHost: com.netflix.hystrix.AbstractCommand
InnerClasses:
private HystrixObservableTimeoutOperator = com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator of com.netflix.hystrix.AbstractCommand
com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$3
protected final TimedOutStatus = com.netflix.hystrix.AbstractCommand$TimedOutStatus of com.netflix.hystrix.AbstractCommand
public abstract TimerListener = com.netflix.hystrix.util.HystrixTimer$TimerListener of com.netflix.hystrix.util.HystrixTimer