public class com.netflix.hystrix.metric.HystrixRequestEventsStream
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.netflix.hystrix.metric.HystrixRequestEventsStream
super_class: java.lang.Object
{
private final rx.subjects.Subject<com.netflix.hystrix.metric.HystrixRequestEvents, com.netflix.hystrix.metric.HystrixRequestEvents> writeOnlyRequestEventsSubject;
descriptor: Lrx/subjects/Subject;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lrx/subjects/Subject<Lcom/netflix/hystrix/metric/HystrixRequestEvents;Lcom/netflix/hystrix/metric/HystrixRequestEvents;>;
private final rx.Observable<com.netflix.hystrix.metric.HystrixRequestEvents> readOnlyRequestEvents;
descriptor: Lrx/Observable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lrx/Observable<Lcom/netflix/hystrix/metric/HystrixRequestEvents;>;
private static final com.netflix.hystrix.metric.HystrixRequestEventsStream INSTANCE;
descriptor: Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new com.netflix.hystrix.metric.HystrixRequestEventsStream
dup
invokespecial com.netflix.hystrix.metric.HystrixRequestEventsStream.<init>:()V
putstatic com.netflix.hystrix.metric.HystrixRequestEventsStream.INSTANCE:Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>();
descriptor: ()V
flags: (0x0000)
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic rx.subjects.PublishSubject.create:()Lrx/subjects/PublishSubject;
putfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
2: aload 0
aload 0
getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
ldc 1024
invokevirtual rx.subjects.Subject.onBackpressureBuffer:(J)Lrx/Observable;
putfield com.netflix.hystrix.metric.HystrixRequestEventsStream.readOnlyRequestEvents:Lrx/Observable;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
public static com.netflix.hystrix.metric.HystrixRequestEventsStream getInstance();
descriptor: ()Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic com.netflix.hystrix.metric.HystrixRequestEventsStream.INSTANCE:Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void shutdown();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
invokevirtual rx.subjects.Subject.onCompleted:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
public void write(java.util.Collection<com.netflix.hystrix.HystrixInvokableInfo<?>>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new com.netflix.hystrix.metric.HystrixRequestEvents
dup
aload 1
invokespecial com.netflix.hystrix.metric.HystrixRequestEvents.<init>:(Ljava/util/Collection;)V
astore 2
start local 2 1: aload 0
getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
aload 2
invokevirtual rx.subjects.Subject.onNext:(Ljava/lang/Object;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
0 3 1 executions Ljava/util/Collection<Lcom/netflix/hystrix/HystrixInvokableInfo<*>;>;
1 3 2 requestEvents Lcom/netflix/hystrix/metric/HystrixRequestEvents;
Signature: (Ljava/util/Collection<Lcom/netflix/hystrix/HystrixInvokableInfo<*>;>;)V
MethodParameters:
Name Flags
executions
public rx.Observable<com.netflix.hystrix.metric.HystrixRequestEvents> observe();
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.metric.HystrixRequestEventsStream.readOnlyRequestEvents:Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/metric/HystrixRequestEventsStream;
Signature: ()Lrx/Observable<Lcom/netflix/hystrix/metric/HystrixRequestEvents;>;
}
SourceFile: "HystrixRequestEventsStream.java"