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: .line 37
            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 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
         0: .line 32
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 33
            aload 0 /* this */
            invokestatic rx.subjects.PublishSubject.create:()Lrx/subjects/PublishSubject;
            putfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
         2: .line 34
            aload 0 /* this */
            aload 0 /* this */
            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: .line 35
            return
        end local 0 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
      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: .line 40
            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 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
         0: .line 44
            aload 0 /* this */
            getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
            invokevirtual rx.subjects.Subject.onCompleted:()V
         1: .line 45
            return
        end local 0 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
      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 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
        start local 1 // java.util.Collection executions
         0: .line 48
            new com.netflix.hystrix.metric.HystrixRequestEvents
            dup
            aload 1 /* executions */
            invokespecial com.netflix.hystrix.metric.HystrixRequestEvents.<init>:(Ljava/util/Collection;)V
            astore 2 /* requestEvents */
        start local 2 // com.netflix.hystrix.metric.HystrixRequestEvents requestEvents
         1: .line 49
            aload 0 /* this */
            getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.writeOnlyRequestEventsSubject:Lrx/subjects/Subject;
            aload 2 /* requestEvents */
            invokevirtual rx.subjects.Subject.onNext:(Ljava/lang/Object;)V
         2: .line 50
            return
        end local 2 // com.netflix.hystrix.metric.HystrixRequestEvents requestEvents
        end local 1 // java.util.Collection executions
        end local 0 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
      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 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
         0: .line 53
            aload 0 /* this */
            getfield com.netflix.hystrix.metric.HystrixRequestEventsStream.readOnlyRequestEvents:Lrx/Observable;
            areturn
        end local 0 // com.netflix.hystrix.metric.HystrixRequestEventsStream this
      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"