public class com.netflix.hystrix.metric.consumer.HystrixDashboardStream
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: com.netflix.hystrix.metric.consumer.HystrixDashboardStream
  super_class: java.lang.Object
{
  final int delayInMs;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  final rx.Observable<com.netflix.hystrix.metric.consumer.HystrixDashboardStream$DashboardData> singleSource;
    descriptor: Lrx/Observable;
    flags: (0x0010) ACC_FINAL
    Signature: Lrx/Observable<Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream$DashboardData;>;

  final java.util.concurrent.atomic.AtomicBoolean isSourceCurrentlySubscribed;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0010) ACC_FINAL

  private static final com.netflix.config.DynamicIntProperty dataEmissionIntervalInMs;
    descriptor: Lcom/netflix/config/DynamicIntProperty;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final com.netflix.hystrix.metric.consumer.HystrixDashboardStream INSTANCE;
    descriptor: Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 37
            invokestatic com.netflix.config.DynamicPropertyFactory.getInstance:()Lcom/netflix/config/DynamicPropertyFactory;
            ldc "hystrix.stream.dashboard.intervalInMilliseconds"
            sipush 500
            invokevirtual com.netflix.config.DynamicPropertyFactory.getIntProperty:(Ljava/lang/String;I)Lcom/netflix/config/DynamicIntProperty;
         1: .line 36
            putstatic com.netflix.hystrix.metric.consumer.HystrixDashboardStream.dataEmissionIntervalInMs:Lcom/netflix/config/DynamicIntProperty;
         2: .line 70
            new com.netflix.hystrix.metric.consumer.HystrixDashboardStream
            dup
            getstatic com.netflix.hystrix.metric.consumer.HystrixDashboardStream.dataEmissionIntervalInMs:Lcom/netflix/config/DynamicIntProperty;
            invokevirtual com.netflix.config.DynamicIntProperty.get:()I
            invokespecial com.netflix.hystrix.metric.consumer.HystrixDashboardStream.<init>:(I)V
         3: .line 69
            putstatic com.netflix.hystrix.metric.consumer.HystrixDashboardStream.INSTANCE:Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
         4: .line 70
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>(int);
    descriptor: (I)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
        start local 1 // int delayInMs
         0: .line 39
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 34
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield com.netflix.hystrix.metric.consumer.HystrixDashboardStream.isSourceCurrentlySubscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 40
            aload 0 /* this */
            iload 1 /* delayInMs */
            putfield com.netflix.hystrix.metric.consumer.HystrixDashboardStream.delayInMs:I
         3: .line 41
            aload 0 /* this */
            iload 1 /* delayInMs */
            i2l
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokestatic rx.Observable.interval:(JLjava/util/concurrent/TimeUnit;)Lrx/Observable;
         4: .line 42
            new com.netflix.hystrix.metric.consumer.HystrixDashboardStream$1
            dup
            aload 0 /* this */
            invokespecial com.netflix.hystrix.metric.consumer.HystrixDashboardStream$1.<init>:(Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         5: .line 52
            new com.netflix.hystrix.metric.consumer.HystrixDashboardStream$2
            dup
            aload 0 /* this */
            invokespecial com.netflix.hystrix.metric.consumer.HystrixDashboardStream$2.<init>:(Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;)V
            invokevirtual rx.Observable.doOnSubscribe:(Lrx/functions/Action0;)Lrx/Observable;
         6: .line 58
            new com.netflix.hystrix.metric.consumer.HystrixDashboardStream$3
            dup
            aload 0 /* this */
            invokespecial com.netflix.hystrix.metric.consumer.HystrixDashboardStream$3.<init>:(Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;)V
            invokevirtual rx.Observable.doOnUnsubscribe:(Lrx/functions/Action0;)Lrx/Observable;
         7: .line 64
            invokevirtual rx.Observable.share:()Lrx/Observable;
         8: .line 65
            invokevirtual rx.Observable.onBackpressureDrop:()Lrx/Observable;
         9: .line 41
            putfield com.netflix.hystrix.metric.consumer.HystrixDashboardStream.singleSource:Lrx/Observable;
        10: .line 66
            return
        end local 1 // int delayInMs
        end local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   11     0       this  Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
            0   11     1  delayInMs  I
    MethodParameters:
           Name  Flags
      delayInMs  

  public static com.netflix.hystrix.metric.consumer.HystrixDashboardStream getInstance();
    descriptor: ()Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 73
            getstatic com.netflix.hystrix.metric.consumer.HystrixDashboardStream.INSTANCE:Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static com.netflix.hystrix.metric.consumer.HystrixDashboardStream getNonSingletonInstanceOnlyUsedInUnitTests(int);
    descriptor: (I)Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // int delayInMs
         0: .line 77
            new com.netflix.hystrix.metric.consumer.HystrixDashboardStream
            dup
            iload 0 /* delayInMs */
            invokespecial com.netflix.hystrix.metric.consumer.HystrixDashboardStream.<init>:(I)V
            areturn
        end local 0 // int delayInMs
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0  delayInMs  I
    MethodParameters:
           Name  Flags
      delayInMs  

  public rx.Observable<com.netflix.hystrix.metric.consumer.HystrixDashboardStream$DashboardData> observe();
    descriptor: ()Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
         0: .line 84
            aload 0 /* this */
            getfield com.netflix.hystrix.metric.consumer.HystrixDashboardStream.singleSource:Lrx/Observable;
            areturn
        end local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
    Signature: ()Lrx/Observable<Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream$DashboardData;>;

  public boolean isSourceCurrentlySubscribed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
         0: .line 88
            aload 0 /* this */
            getfield com.netflix.hystrix.metric.consumer.HystrixDashboardStream.isSourceCurrentlySubscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ireturn
        end local 0 // com.netflix.hystrix.metric.consumer.HystrixDashboardStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/netflix/hystrix/metric/consumer/HystrixDashboardStream;
}
SourceFile: "HystrixDashboardStream.java"
NestMembers:
  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$1  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$2  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$3  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$DashboardData
InnerClasses:
  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$1
  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$2
  com.netflix.hystrix.metric.consumer.HystrixDashboardStream$3
  public DashboardData = com.netflix.hystrix.metric.consumer.HystrixDashboardStream$DashboardData of com.netflix.hystrix.metric.consumer.HystrixDashboardStream