public class com.netflix.hystrix.HystrixCachedObservable<R>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.netflix.hystrix.HystrixCachedObservable
super_class: java.lang.Object
{
protected final rx.Subscription originalSubscription;
descriptor: Lrx/Subscription;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final rx.Observable<R> cachedObservable;
descriptor: Lrx/Observable;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Lrx/Observable<TR;>;
private volatile int outstandingSubscriptions;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
protected void <init>(rx.Observable<R>);
descriptor: (Lrx/Observable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iconst_0
putfield com.netflix.hystrix.HystrixCachedObservable.outstandingSubscriptions:I
2: invokestatic rx.subjects.ReplaySubject.create:()Lrx/subjects/ReplaySubject;
astore 2
start local 2 3: aload 0
aload 1
4: aload 2
invokevirtual rx.Observable.subscribe:(Lrx/Observer;)Lrx/Subscription;
5: putfield com.netflix.hystrix.HystrixCachedObservable.originalSubscription:Lrx/Subscription;
6: aload 0
aload 2
7: new com.netflix.hystrix.HystrixCachedObservable$1
dup
aload 0
invokespecial com.netflix.hystrix.HystrixCachedObservable$1.<init>:(Lcom/netflix/hystrix/HystrixCachedObservable;)V
invokevirtual rx.subjects.ReplaySubject.doOnUnsubscribe:(Lrx/functions/Action0;)Lrx/Observable;
8: new com.netflix.hystrix.HystrixCachedObservable$2
dup
aload 0
invokespecial com.netflix.hystrix.HystrixCachedObservable$2.<init>:(Lcom/netflix/hystrix/HystrixCachedObservable;)V
invokevirtual rx.Observable.doOnSubscribe:(Lrx/functions/Action0;)Lrx/Observable;
9: putfield com.netflix.hystrix.HystrixCachedObservable.cachedObservable:Lrx/Observable;
10: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lcom/netflix/hystrix/HystrixCachedObservable<TR;>;
0 11 1 originalObservable Lrx/Observable<TR;>;
3 11 2 replaySubject Lrx/subjects/ReplaySubject<TR;>;
Signature: (Lrx/Observable<TR;>;)V
MethodParameters:
Name Flags
originalObservable final
public static <R> com.netflix.hystrix.HystrixCachedObservable<R> from(rx.Observable<R>, com.netflix.hystrix.AbstractCommand<R>);
descriptor: (Lrx/Observable;Lcom/netflix/hystrix/AbstractCommand;)Lcom/netflix/hystrix/HystrixCachedObservable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new com.netflix.hystrix.HystrixCommandResponseFromCache
dup
aload 0
aload 1
invokespecial com.netflix.hystrix.HystrixCommandResponseFromCache.<init>:(Lrx/Observable;Lcom/netflix/hystrix/AbstractCommand;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 o Lrx/Observable<TR;>;
0 1 1 originalCommand Lcom/netflix/hystrix/AbstractCommand<TR;>;
Signature: <R:Ljava/lang/Object;>(Lrx/Observable<TR;>;Lcom/netflix/hystrix/AbstractCommand<TR;>;)Lcom/netflix/hystrix/HystrixCachedObservable<TR;>;
MethodParameters:
Name Flags
o
originalCommand
public static <R> com.netflix.hystrix.HystrixCachedObservable<R> from(rx.Observable<R>);
descriptor: (Lrx/Observable;)Lcom/netflix/hystrix/HystrixCachedObservable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.netflix.hystrix.HystrixCachedObservable
dup
aload 0
invokespecial com.netflix.hystrix.HystrixCachedObservable.<init>:(Lrx/Observable;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 o Lrx/Observable<TR;>;
Signature: <R:Ljava/lang/Object;>(Lrx/Observable<TR;>;)Lcom/netflix/hystrix/HystrixCachedObservable<TR;>;
MethodParameters:
Name Flags
o
public rx.Observable<R> toObservable();
descriptor: ()Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.HystrixCachedObservable.cachedObservable:Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/HystrixCachedObservable<TR;>;
Signature: ()Lrx/Observable<TR;>;
public void unsubscribe();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.HystrixCachedObservable.originalSubscription:Lrx/Subscription;
invokeinterface rx.Subscription.unsubscribe:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/netflix/hystrix/HystrixCachedObservable<TR;>;
}
Signature: <R:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "HystrixCachedObservable.java"
NestMembers:
com.netflix.hystrix.HystrixCachedObservable$1 com.netflix.hystrix.HystrixCachedObservable$2
InnerClasses:
com.netflix.hystrix.HystrixCachedObservable$1
com.netflix.hystrix.HystrixCachedObservable$2