final class io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber<T> extends io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber<T> implements io.reactivex.FlowableSubscriber<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber
  super_class: io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber
{
  private static final long serialVersionUID;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: -4547113800637756442

  final org.reactivestreams.Subscriber<? super T> downstream;
    descriptor: Lorg/reactivestreams/Subscriber;
    flags: (0x0010) ACC_FINAL
    Signature: Lorg/reactivestreams/Subscriber<-TT;>;

  void <init>(org.reactivestreams.Subscriber<? super T>, io.reactivex.Scheduler$Worker, boolean, );
    descriptor: (Lorg/reactivestreams/Subscriber;Lio/reactivex/Scheduler$Worker;ZI)V
    flags: (0x0000) 
    Code:
      stack=4, locals=5, args_size=5
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
        start local 1 // org.reactivestreams.Subscriber actual
        start local 2 // io.reactivex.Scheduler$Worker worker
        start local 3 // boolean delayError
        start local 4 // int prefetch
         0: .line 257
            aload 0 /* this */
            aload 2 /* worker */
            iload 3 /* delayError */
            iload 4 /* prefetch */
            invokespecial io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.<init>:(Lio/reactivex/Scheduler$Worker;ZI)V
         1: .line 258
            aload 0 /* this */
            aload 1 /* actual */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
         2: .line 259
            return
        end local 4 // int prefetch
        end local 3 // boolean delayError
        end local 2 // io.reactivex.Scheduler$Worker worker
        end local 1 // org.reactivestreams.Subscriber actual
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            0    3     1      actual  Lorg/reactivestreams/Subscriber<-TT;>;
            0    3     2      worker  Lio/reactivex/Scheduler$Worker;
            0    3     3  delayError  Z
            0    3     4    prefetch  I
    Signature: (Lorg/reactivestreams/Subscriber<-TT;>;Lio/reactivex/Scheduler$Worker;ZI)V
    MethodParameters:
            Name  Flags
      actual      
      worker      
      delayError  
      prefetch    

  public void onSubscribe(org.reactivestreams.Subscription);
    descriptor: (Lorg/reactivestreams/Subscription;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
        start local 1 // org.reactivestreams.Subscription s
         0: .line 263
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
            aload 1 /* s */
            invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
            ifeq 20
         1: .line 264
            aload 0 /* this */
            aload 1 /* s */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
         2: .line 266
            aload 1 /* s */
            instanceof io.reactivex.internal.fuseable.QueueSubscription
            ifeq 17
         3: .line 268
            aload 1 /* s */
            checkcast io.reactivex.internal.fuseable.QueueSubscription
            astore 2 /* f */
        start local 2 // io.reactivex.internal.fuseable.QueueSubscription f
         4: .line 270
            aload 2 /* f */
            bipush 7
            invokeinterface io.reactivex.internal.fuseable.QueueSubscription.requestFusion:(I)I
            istore 3 /* m */
        start local 3 // int m
         5: .line 272
            iload 3 /* m */
            iconst_1
            if_icmpne 11
         6: .line 273
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.sourceMode:I
         7: .line 274
            aload 0 /* this */
            aload 2 /* f */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
         8: .line 275
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.done:Z
         9: .line 277
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            aload 0 /* this */
            invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
        10: .line 278
            return
        11: .line 280
      StackMap locals: io.reactivex.internal.fuseable.QueueSubscription int
      StackMap stack:
            iload 3 /* m */
            iconst_2
            if_icmpne 17
        12: .line 281
            aload 0 /* this */
            iconst_2
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.sourceMode:I
        13: .line 282
            aload 0 /* this */
            aload 2 /* f */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
        14: .line 284
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            aload 0 /* this */
            invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
        15: .line 286
            aload 1 /* s */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.prefetch:I
            i2l
            invokeinterface org.reactivestreams.Subscription.request:(J)V
        16: .line 288
            return
        end local 3 // int m
        end local 2 // io.reactivex.internal.fuseable.QueueSubscription f
        17: .line 292
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new io.reactivex.internal.queue.SpscArrayQueue
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.prefetch:I
            invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
        18: .line 294
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            aload 0 /* this */
            invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
        19: .line 296
            aload 1 /* s */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.prefetch:I
            i2l
            invokeinterface org.reactivestreams.Subscription.request:(J)V
        20: .line 298
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.reactivestreams.Subscription s
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   21     0  this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            0   21     1     s  Lorg/reactivestreams/Subscription;
            4   17     2     f  Lio/reactivex/internal/fuseable/QueueSubscription<TT;>;
            5   17     3     m  I
    MethodParameters:
      Name  Flags
      s     

  void runSync();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=4, locals=10, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
         0: .line 302
            iconst_1
            istore 1 /* missed */
        start local 1 // int missed
         1: .line 304
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            astore 2 /* a */
        start local 2 // org.reactivestreams.Subscriber a
         2: .line 305
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 3 /* q */
        start local 3 // io.reactivex.internal.fuseable.SimpleQueue q
         3: .line 307
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
            lstore 4 /* e */
        start local 4 // long e
         4: .line 311
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber int org.reactivestreams.Subscriber io.reactivex.internal.fuseable.SimpleQueue long
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lstore 6 /* r */
        start local 6 // long r
         5: .line 313
            goto 24
         6: .line 317
      StackMap locals: long
      StackMap stack:
            aload 3 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 8 /* v */
        start local 8 // java.lang.Object v
         7: .line 318
            goto 15
        end local 8 // java.lang.Object v
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: astore 9 /* ex */
        start local 9 // java.lang.Throwable ex
         9: .line 319
            aload 9 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        10: .line 320
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
        11: .line 321
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
            invokeinterface org.reactivestreams.Subscription.cancel:()V
        12: .line 322
            aload 2 /* a */
            aload 9 /* ex */
            invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
        13: .line 323
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.worker:Lio/reactivex/Scheduler$Worker;
            invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
        14: .line 324
            return
        end local 9 // java.lang.Throwable ex
        start local 8 // java.lang.Object v
        15: .line 327
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
            ifeq 17
        16: .line 328
            return
        17: .line 330
      StackMap locals:
      StackMap stack:
            aload 8 /* v */
            ifnonnull 22
        18: .line 331
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
        19: .line 332
            aload 2 /* a */
            invokeinterface org.reactivestreams.Subscriber.onComplete:()V
        20: .line 333
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.worker:Lio/reactivex/Scheduler$Worker;
            invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
        21: .line 334
            return
        22: .line 337
      StackMap locals:
      StackMap stack:
            aload 2 /* a */
            aload 8 /* v */
            invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
        23: .line 339
            lload 4 /* e */
            lconst_1
            ladd
            lstore 4 /* e */
        end local 8 // java.lang.Object v
        24: .line 313
      StackMap locals:
      StackMap stack:
            lload 4 /* e */
            lload 6 /* r */
            lcmp
            ifne 6
        25: .line 342
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
            ifeq 27
        26: .line 343
            return
        27: .line 346
      StackMap locals:
      StackMap stack:
            aload 3 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
            ifeq 32
        28: .line 347
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
        29: .line 348
            aload 2 /* a */
            invokeinterface org.reactivestreams.Subscriber.onComplete:()V
        30: .line 349
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.worker:Lio/reactivex/Scheduler$Worker;
            invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
        31: .line 350
            return
        32: .line 353
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.get:()I
            istore 8 /* w */
        start local 8 // int w
        33: .line 354
            iload 1 /* missed */
            iload 8 /* w */
            if_icmpne 38
        34: .line 355
            aload 0 /* this */
            lload 4 /* e */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
        35: .line 356
            aload 0 /* this */
            iload 1 /* missed */
            ineg
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.addAndGet:(I)I
            istore 1 /* missed */
        36: .line 357
            iload 1 /* missed */
            ifne 4
        37: .line 358
            goto 40
        38: .line 361
      StackMap locals: int
      StackMap stack:
            iload 8 /* w */
            istore 1 /* missed */
        end local 8 // int w
        end local 6 // long r
        39: .line 309
            goto 4
        40: .line 364
      StackMap locals:
      StackMap stack:
            return
        end local 4 // long e
        end local 3 // io.reactivex.internal.fuseable.SimpleQueue q
        end local 2 // org.reactivestreams.Subscriber a
        end local 1 // int missed
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   41     0    this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            1   41     1  missed  I
            2   41     2       a  Lorg/reactivestreams/Subscriber<-TT;>;
            3   41     3       q  Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
            4   41     4       e  J
            5   39     6       r  J
            7    8     8       v  TT;
           15   24     8       v  TT;
            9   15     9      ex  Ljava/lang/Throwable;
           33   39     8       w  I
      Exception table:
        from    to  target  type
           6     7       8  Class java.lang.Throwable

  void runAsync();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=4, locals=11, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
         0: .line 368
            iconst_1
            istore 1 /* missed */
        start local 1 // int missed
         1: .line 370
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            astore 2 /* a */
        start local 2 // org.reactivestreams.Subscriber a
         2: .line 371
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 3 /* q */
        start local 3 // io.reactivex.internal.fuseable.SimpleQueue q
         3: .line 373
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
            lstore 4 /* e */
        start local 4 // long e
         4: .line 377
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber int org.reactivestreams.Subscriber io.reactivex.internal.fuseable.SimpleQueue long
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lstore 6 /* r */
        start local 6 // long r
         5: .line 379
            goto 31
         6: .line 380
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.done:Z
            istore 8 /* d */
        start local 8 // boolean d
         7: .line 384
            aload 3 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 9 /* v */
        start local 9 // java.lang.Object v
         8: .line 385
            goto 17
        end local 9 // java.lang.Object v
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber int org.reactivestreams.Subscriber io.reactivex.internal.fuseable.SimpleQueue long long int
      StackMap stack: java.lang.Throwable
         9: astore 10 /* ex */
        start local 10 // java.lang.Throwable ex
        10: .line 386
            aload 10 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        11: .line 388
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
        12: .line 389
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
            invokeinterface org.reactivestreams.Subscription.cancel:()V
        13: .line 390
            aload 3 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.clear:()V
        14: .line 392
            aload 2 /* a */
            aload 10 /* ex */
            invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
        15: .line 393
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.worker:Lio/reactivex/Scheduler$Worker;
            invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
        16: .line 394
            return
        end local 10 // java.lang.Throwable ex
        start local 9 // java.lang.Object v
        17: .line 397
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 9 /* v */
            ifnonnull 18
            iconst_1
            goto 19
      StackMap locals:
      StackMap stack:
        18: iconst_0
      StackMap locals:
      StackMap stack: int
        19: istore 10 /* empty */
        start local 10 // boolean empty
        20: .line 399
            aload 0 /* this */
            iload 8 /* d */
            iload 10 /* empty */
            aload 2 /* a */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.checkTerminated:(ZZLorg/reactivestreams/Subscriber;)Z
            ifeq 22
        21: .line 400
            return
        22: .line 403
      StackMap locals: int
      StackMap stack:
            iload 10 /* empty */
            ifeq 24
        23: .line 404
            goto 32
        24: .line 407
      StackMap locals:
      StackMap stack:
            aload 2 /* a */
            aload 9 /* v */
            invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
        25: .line 409
            lload 4 /* e */
            lconst_1
            ladd
            lstore 4 /* e */
        26: .line 410
            lload 4 /* e */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.limit:I
            i2l
            lcmp
            ifne 31
        27: .line 411
            lload 6 /* r */
            ldc 9223372036854775807
            lcmp
            ifeq 29
        28: .line 412
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
            lload 4 /* e */
            lneg
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            lstore 6 /* r */
        29: .line 414
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
            lload 4 /* e */
            invokeinterface org.reactivestreams.Subscription.request:(J)V
        30: .line 415
            lconst_0
            lstore 4 /* e */
        end local 10 // boolean empty
        end local 9 // java.lang.Object v
        end local 8 // boolean d
        31: .line 379
      StackMap locals:
      StackMap stack:
            lload 4 /* e */
            lload 6 /* r */
            lcmp
            ifne 6
        32: .line 419
      StackMap locals:
      StackMap stack:
            lload 4 /* e */
            lload 6 /* r */
            lcmp
            ifne 34
            aload 0 /* this */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.done:Z
            aload 3 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
            aload 2 /* a */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.checkTerminated:(ZZLorg/reactivestreams/Subscriber;)Z
            ifeq 34
        33: .line 420
            return
        34: .line 423
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.get:()I
            istore 8 /* w */
        start local 8 // int w
        35: .line 424
            iload 1 /* missed */
            iload 8 /* w */
            if_icmpne 40
        36: .line 425
            aload 0 /* this */
            lload 4 /* e */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
        37: .line 426
            aload 0 /* this */
            iload 1 /* missed */
            ineg
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.addAndGet:(I)I
            istore 1 /* missed */
        38: .line 427
            iload 1 /* missed */
            ifne 4
        39: .line 428
            goto 42
        40: .line 431
      StackMap locals: int
      StackMap stack:
            iload 8 /* w */
            istore 1 /* missed */
        end local 8 // int w
        end local 6 // long r
        41: .line 375
            goto 4
        42: .line 434
      StackMap locals:
      StackMap stack:
            return
        end local 4 // long e
        end local 3 // io.reactivex.internal.fuseable.SimpleQueue q
        end local 2 // org.reactivestreams.Subscriber a
        end local 1 // int missed
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   43     0    this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            1   43     1  missed  I
            2   43     2       a  Lorg/reactivestreams/Subscriber<-TT;>;
            3   43     3       q  Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
            4   43     4       e  J
            5   41     6       r  J
            7   31     8       d  Z
            8    9     9       v  TT;
           17   31     9       v  TT;
           10   17    10      ex  Ljava/lang/Throwable;
           20   31    10   empty  Z
           35   41     8       w  I
      Exception table:
        from    to  target  type
           7     8       9  Class java.lang.Throwable

  void runBackfused();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
         0: .line 438
            iconst_1
            istore 1 /* missed */
        start local 1 // int missed
         1: .line 442
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
            ifeq 3
         2: .line 443
            return
         3: .line 446
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.done:Z
            istore 2 /* d */
        start local 2 // boolean d
         4: .line 448
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            aconst_null
            invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
         5: .line 450
            iload 2 /* d */
            ifeq 14
         6: .line 451
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.cancelled:Z
         7: .line 452
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.error:Ljava/lang/Throwable;
            astore 3 /* e */
        start local 3 // java.lang.Throwable e
         8: .line 453
            aload 3 /* e */
            ifnull 11
         9: .line 454
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            aload 3 /* e */
            invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
        10: .line 455
            goto 12
        11: .line 456
      StackMap locals: int java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.downstream:Lorg/reactivestreams/Subscriber;
            invokeinterface org.reactivestreams.Subscriber.onComplete:()V
        12: .line 458
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.worker:Lio/reactivex/Scheduler$Worker;
            invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
        13: .line 459
            return
        end local 3 // java.lang.Throwable e
        14: .line 462
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* missed */
            ineg
            invokevirtual io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.addAndGet:(I)I
            istore 1 /* missed */
        15: .line 463
            iload 1 /* missed */
            ifne 1
        end local 2 // boolean d
        16: .line 467
            return
        end local 1 // int missed
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   17     0    this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            1   17     1  missed  I
            4   16     2       d  Z
            8   14     3       e  Ljava/lang/Throwable;

  public T poll();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
         0: .line 472
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 1 /* v */
        start local 1 // java.lang.Object v
         1: .line 473
            aload 1 /* v */
            ifnull 8
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.sourceMode:I
            iconst_1
            if_icmpeq 8
         2: .line 474
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
            lconst_1
            ladd
            lstore 2 /* p */
        start local 2 // long p
         3: .line 475
            lload 2 /* p */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.limit:I
            i2l
            lcmp
            ifne 7
         4: .line 476
            aload 0 /* this */
            lconst_0
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
         5: .line 477
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.upstream:Lorg/reactivestreams/Subscription;
            lload 2 /* p */
            invokeinterface org.reactivestreams.Subscription.request:(J)V
         6: .line 478
            goto 8
         7: .line 479
      StackMap locals: java.lang.Object long
      StackMap stack:
            aload 0 /* this */
            lload 2 /* p */
            putfield io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.produced:J
        end local 2 // long p
         8: .line 482
      StackMap locals:
      StackMap stack:
            aload 1 /* v */
            areturn
        end local 1 // java.lang.Object v
        end local 0 // io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/reactivex/internal/operators/flowable/FlowableObserveOn$ObserveOnSubscriber<TT;>;
            1    9     1     v  TT;
            3    8     2     p  J
    Exceptions:
      throws java.lang.Exception
    Signature: ()TT;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.Nullable()
}
Signature: <T:Ljava/lang/Object;>Lio/reactivex/internal/operators/flowable/FlowableObserveOn$BaseObserveOnSubscriber<TT;>;Lio/reactivex/FlowableSubscriber<TT;>;
SourceFile: "FlowableObserveOn.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableObserveOn
InnerClasses:
  public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
  abstract BaseObserveOnSubscriber = io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber of io.reactivex.internal.operators.flowable.FlowableObserveOn
  final ObserveOnSubscriber = io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber of io.reactivex.internal.operators.flowable.FlowableObserveOn