final class io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver<T, U> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.disposables.Disposable, io.reactivex.Observer<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
  super_class: java.util.concurrent.atomic.AtomicInteger
{
  private static final long serialVersionUID;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: -2117620485640801370

  final io.reactivex.Observer<? super U> downstream;
    descriptor: Lio/reactivex/Observer;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/Observer<-TU;>;

  final io.reactivex.functions.Function<? super T, ? extends io.reactivex.ObservableSource<? extends U>> mapper;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/functions/Function<-TT;+Lio/reactivex/ObservableSource<+TU;>;>;

  final boolean delayErrors;
    descriptor: Z
    flags: (0x0010) ACC_FINAL

  final int maxConcurrency;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  final int bufferSize;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  volatile io.reactivex.internal.fuseable.SimplePlainQueue<U> queue;
    descriptor: Lio/reactivex/internal/fuseable/SimplePlainQueue;
    flags: (0x0040) ACC_VOLATILE
    Signature: Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;

  volatile boolean done;
    descriptor: Z
    flags: (0x0040) ACC_VOLATILE

  final io.reactivex.internal.util.AtomicThrowable errors;
    descriptor: Lio/reactivex/internal/util/AtomicThrowable;
    flags: (0x0010) ACC_FINAL

  volatile boolean cancelled;
    descriptor: Z
    flags: (0x0040) ACC_VOLATILE

  final java.util.concurrent.atomic.AtomicReference<io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<?, ?>[]> observers;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<**>;>;

  static final io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<?, ?>[] EMPTY;
    descriptor: [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<**>;

  static final io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<?, ?>[] CANCELLED;
    descriptor: [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<**>;

  io.reactivex.disposables.Disposable upstream;
    descriptor: Lio/reactivex/disposables/Disposable;
    flags: (0x0000) 

  long uniqueId;
    descriptor: J
    flags: (0x0000) 

  long lastId;
    descriptor: J
    flags: (0x0000) 

  int lastIndex;
    descriptor: I
    flags: (0x0000) 

  java.util.Queue<io.reactivex.ObservableSource<? extends U>> sources;
    descriptor: Ljava/util/Queue;
    flags: (0x0000) 
    Signature: Ljava/util/Queue<Lio/reactivex/ObservableSource<+TU;>;>;

  int wip;
    descriptor: I
    flags: (0x0000) 

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 78
            iconst_0
            anewarray io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver
            putstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.EMPTY:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
         1: .line 80
            iconst_0
            anewarray io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver
            putstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.CANCELLED:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(io.reactivex.Observer<? super U>, io.reactivex.functions.Function<? super T, ? extends io.reactivex.ObservableSource<? extends U>>, boolean, int, );
    descriptor: (Lio/reactivex/Observer;Lio/reactivex/functions/Function;ZII)V
    flags: (0x0000) 
    Code:
      stack=4, locals=6, args_size=6
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // io.reactivex.Observer actual
        start local 2 // io.reactivex.functions.Function mapper
        start local 3 // boolean delayErrors
        start local 4 // int maxConcurrency
        start local 5 // int bufferSize
         0: .line 92
            aload 0 /* this */
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
         1: .line 72
            aload 0 /* this */
            new io.reactivex.internal.util.AtomicThrowable
            dup
            invokespecial io.reactivex.internal.util.AtomicThrowable.<init>:()V
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
         2: .line 94
            aload 0 /* this */
            aload 1 /* actual */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
         3: .line 95
            aload 0 /* this */
            aload 2 /* mapper */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.mapper:Lio/reactivex/functions/Function;
         4: .line 96
            aload 0 /* this */
            iload 3 /* delayErrors */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.delayErrors:Z
         5: .line 97
            aload 0 /* this */
            iload 4 /* maxConcurrency */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
         6: .line 98
            aload 0 /* this */
            iload 5 /* bufferSize */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.bufferSize:I
         7: .line 99
            iload 4 /* maxConcurrency */
            ldc 2147483647
            if_icmpeq 9
         8: .line 100
            aload 0 /* this */
            new java.util.ArrayDeque
            dup
            iload 4 /* maxConcurrency */
            invokespecial java.util.ArrayDeque.<init>:(I)V
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.sources:Ljava/util/Queue;
         9: .line 102
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer io.reactivex.functions.Function int int int
      StackMap stack:
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.EMPTY:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
        10: .line 103
            return
        end local 5 // int bufferSize
        end local 4 // int maxConcurrency
        end local 3 // boolean delayErrors
        end local 2 // io.reactivex.functions.Function mapper
        end local 1 // io.reactivex.Observer actual
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   11     0            this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   11     1          actual  Lio/reactivex/Observer<-TU;>;
            0   11     2          mapper  Lio/reactivex/functions/Function<-TT;+Lio/reactivex/ObservableSource<+TU;>;>;
            0   11     3     delayErrors  Z
            0   11     4  maxConcurrency  I
            0   11     5      bufferSize  I
    Signature: (Lio/reactivex/Observer<-TU;>;Lio/reactivex/functions/Function<-TT;+Lio/reactivex/ObservableSource<+TU;>;>;ZII)V
    MethodParameters:
                Name  Flags
      actual          
      mapper          
      delayErrors     
      maxConcurrency  
      bufferSize      

  public void onSubscribe(io.reactivex.disposables.Disposable);
    descriptor: (Lio/reactivex/disposables/Disposable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // io.reactivex.disposables.Disposable d
         0: .line 107
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.upstream:Lio/reactivex/disposables/Disposable;
            aload 1 /* d */
            invokestatic io.reactivex.internal.disposables.DisposableHelper.validate:(Lio/reactivex/disposables/Disposable;Lio/reactivex/disposables/Disposable;)Z
            ifeq 3
         1: .line 108
            aload 0 /* this */
            aload 1 /* d */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.upstream:Lio/reactivex/disposables/Disposable;
         2: .line 109
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
            aload 0 /* this */
            invokeinterface io.reactivex.Observer.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
         3: .line 111
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.reactivex.disposables.Disposable d
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0    4     1     d  Lio/reactivex/disposables/Disposable;
    MethodParameters:
      Name  Flags
      d     

  public void onNext();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // java.lang.Object t
         0: .line 116
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
            ifeq 2
         1: .line 117
            return
         2: .line 121
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.mapper:Lio/reactivex/functions/Function;
            aload 1 /* t */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.ObservableSource
            ldc "The mapper returned a null ObservableSource"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.ObservableSource
            astore 2 /* p */
        start local 2 // io.reactivex.ObservableSource p
         3: .line 122
            goto 9
        end local 2 // io.reactivex.ObservableSource p
      StackMap locals:
      StackMap stack: java.lang.Throwable
         4: astore 3 /* e */
        start local 3 // java.lang.Throwable e
         5: .line 123
            aload 3 /* e */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         6: .line 124
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.upstream:Lio/reactivex/disposables/Disposable;
            invokeinterface io.reactivex.disposables.Disposable.dispose:()V
         7: .line 125
            aload 0 /* this */
            aload 3 /* e */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.onError:(Ljava/lang/Throwable;)V
         8: .line 126
            return
        end local 3 // java.lang.Throwable e
        start local 2 // io.reactivex.ObservableSource p
         9: .line 129
      StackMap locals: io.reactivex.ObservableSource
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            ldc 2147483647
            if_icmpeq 20
        10: .line 130
            aload 0 /* this */
            dup
            astore 3
            monitorenter
        11: .line 131
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            if_icmpne 15
        12: .line 132
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.sources:Ljava/util/Queue;
            aload 2 /* p */
            invokeinterface java.util.Queue.offer:(Ljava/lang/Object;)Z
            pop
        13: .line 133
            aload 3
            monitorexit
        14: return
        15: .line 135
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
            iconst_1
            iadd
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
        16: .line 130
            aload 3
            monitorexit
        17: goto 20
      StackMap locals:
      StackMap stack: java.lang.Throwable
        18: aload 3
            monitorexit
        19: athrow
        20: .line 139
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* p */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.subscribeInner:(Lio/reactivex/ObservableSource;)V
        21: .line 140
            return
        end local 2 // io.reactivex.ObservableSource p
        end local 1 // java.lang.Object t
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   22     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   22     1     t  TT;
            3    4     2     p  Lio/reactivex/ObservableSource<+TU;>;
            9   22     2     p  Lio/reactivex/ObservableSource<+TU;>;
            5    9     3     e  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.Throwable
          11    14      18  any
          15    17      18  any
          18    19      18  any
    Signature: (TT;)V
    MethodParameters:
      Name  Flags
      t     

  void subscribeInner(io.reactivex.ObservableSource<? extends U>);
    descriptor: (Lio/reactivex/ObservableSource;)V
    flags: (0x0000) 
    Code:
      stack=10, locals=4, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // io.reactivex.ObservableSource p
         0: .line 145
      StackMap locals:
      StackMap stack:
            aload 1 /* p */
            instanceof java.util.concurrent.Callable
            ifeq 15
         1: .line 146
            aload 0 /* this */
            aload 1 /* p */
            checkcast java.util.concurrent.Callable
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.tryEmitScalar:(Ljava/util/concurrent/Callable;)Z
            ifeq 18
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            ldc 2147483647
            if_icmpeq 18
         2: .line 147
            iconst_0
            istore 2 /* empty */
        start local 2 // boolean empty
         3: .line 148
            aload 0 /* this */
            dup
            astore 3
            monitorenter
         4: .line 149
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.sources:Ljava/util/Queue;
            invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
            checkcast io.reactivex.ObservableSource
            astore 1 /* p */
         5: .line 150
            aload 1 /* p */
            ifnonnull 8
         6: .line 151
            aload 0 /* this */
            dup
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
            iconst_1
            isub
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
         7: .line 152
            iconst_1
            istore 2 /* empty */
         8: .line 148
      StackMap locals: int io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
      StackMap stack:
            aload 3
            monitorexit
         9: goto 12
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: aload 3
            monitorexit
        11: athrow
        12: .line 155
      StackMap locals:
      StackMap stack:
            iload 2 /* empty */
            ifeq 0
        13: .line 156
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain:()V
        14: .line 157
            goto 18
        end local 2 // boolean empty
        15: .line 163
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver
            dup
            aload 0 /* this */
            aload 0 /* this */
            dup
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.uniqueId:J
            dup2_x1
            lconst_1
            ladd
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.uniqueId:J
            invokespecial io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.<init>:(Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver;J)V
            astore 2 /* inner */
        start local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
        16: .line 164
            aload 0 /* this */
            aload 2 /* inner */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.addInner:(Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)Z
            ifeq 18
        17: .line 165
            aload 1 /* p */
            aload 2 /* inner */
            invokeinterface io.reactivex.ObservableSource.subscribe:(Lio/reactivex/Observer;)V
        end local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
        18: .line 170
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.reactivex.ObservableSource p
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   19     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   19     1      p  Lio/reactivex/ObservableSource<+TU;>;
            3   15     2  empty  Z
           16   18     2  inner  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;
      Exception table:
        from    to  target  type
           4     9      10  any
          10    11      10  any
    Signature: (Lio/reactivex/ObservableSource<+TU;>;)V
    MethodParameters:
      Name  Flags
      p     

  boolean addInner(io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<T, U>);
    descriptor: (Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)Z
    flags: (0x0000) 
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
         0: .line 174
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
            astore 2 /* a */
        start local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
         1: .line 175
            aload 2 /* a */
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.CANCELLED:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            if_acmpne 4
         2: .line 176
            aload 1 /* inner */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.dispose:()V
         3: .line 177
            iconst_0
            ireturn
         4: .line 179
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
      StackMap stack:
            aload 2 /* a */
            arraylength
            istore 3 /* n */
        start local 3 // int n
         5: .line 180
            iload 3 /* n */
            iconst_1
            iadd
            anewarray io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver
            astore 4 /* b */
        start local 4 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
         6: .line 181
            aload 2 /* a */
            iconst_0
            aload 4 /* b */
            iconst_0
            iload 3 /* n */
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
         7: .line 182
            aload 4 /* b */
            iload 3 /* n */
            aload 1 /* inner */
            aastore
         8: .line 183
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            aload 2 /* a */
            aload 4 /* b */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
         9: .line 184
            iconst_1
            ireturn
        end local 4 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
        end local 3 // int n
        end local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
        end local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   10     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   10     1  inner  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;
            1   10     2      a  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            5   10     3      n  I
            6   10     4      b  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
    Signature: (Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;)Z
    MethodParameters:
       Name  Flags
      inner  

  void removeInner(io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<T, U>);
    descriptor: (Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=6, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
         0: .line 191
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
            astore 2 /* a */
        start local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
         1: .line 192
            aload 2 /* a */
            arraylength
            istore 3 /* n */
        start local 3 // int n
         2: .line 193
            iload 3 /* n */
            ifne 4
         3: .line 194
            return
         4: .line 196
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int
      StackMap stack:
            iconst_m1
            istore 4 /* j */
        start local 4 // int j
         5: .line 197
            iconst_0
            istore 5 /* i */
        start local 5 // int i
         6: goto 11
         7: .line 198
      StackMap locals: int int
      StackMap stack:
            aload 2 /* a */
            iload 5 /* i */
            aaload
            aload 1 /* inner */
            if_acmpne 10
         8: .line 199
            iload 5 /* i */
            istore 4 /* j */
         9: .line 200
            goto 12
        10: .line 197
      StackMap locals:
      StackMap stack:
            iinc 5 /* i */ 1
      StackMap locals:
      StackMap stack:
        11: iload 5 /* i */
            iload 3 /* n */
            if_icmplt 7
        end local 5 // int i
        12: .line 203
      StackMap locals:
      StackMap stack:
            iload 4 /* j */
            ifge 14
        13: .line 204
            return
        14: .line 207
      StackMap locals:
      StackMap stack:
            iload 3 /* n */
            iconst_1
            if_icmpne 17
        15: .line 208
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.EMPTY:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            astore 5 /* b */
        start local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
        16: .line 209
            goto 20
        end local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
        17: .line 210
      StackMap locals:
      StackMap stack:
            iload 3 /* n */
            iconst_1
            isub
            anewarray io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver
            astore 5 /* b */
        start local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
        18: .line 211
            aload 2 /* a */
            iconst_0
            aload 5 /* b */
            iconst_0
            iload 4 /* j */
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
        19: .line 212
            aload 2 /* a */
            iload 4 /* j */
            iconst_1
            iadd
            aload 5 /* b */
            iload 4 /* j */
            iload 3 /* n */
            iload 4 /* j */
            isub
            iconst_1
            isub
            invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
        20: .line 214
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            aload 2 /* a */
            aload 5 /* b */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
        21: .line 215
            return
        end local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] b
        end local 4 // int j
        end local 3 // int n
        end local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
        end local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   22     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   22     1  inner  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;
            1   22     2      a  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            2   22     3      n  I
            5   22     4      j  I
            6   12     5      i  I
           16   17     5      b  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
           18   22     5      b  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
    Signature: (Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;)V
    MethodParameters:
       Name  Flags
      inner  

  boolean tryEmitScalar(java.util.concurrent.Callable<? extends U>);
    descriptor: (Ljava/util/concurrent/Callable;)Z
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // java.util.concurrent.Callable value
         0: .line 223
            aload 1 /* value */
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 2 /* u */
        start local 2 // java.lang.Object u
         1: .line 224
            goto 7
        end local 2 // java.lang.Object u
      StackMap locals:
      StackMap stack: java.lang.Throwable
         2: astore 3 /* ex */
        start local 3 // java.lang.Throwable ex
         3: .line 225
            aload 3 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         4: .line 226
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            aload 3 /* ex */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            pop
         5: .line 227
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain:()V
         6: .line 228
            iconst_1
            ireturn
        end local 3 // java.lang.Throwable ex
        start local 2 // java.lang.Object u
         7: .line 231
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 2 /* u */
            ifnonnull 9
         8: .line 232
            iconst_1
            ireturn
         9: .line 235
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.get:()I
            ifne 13
            aload 0 /* this */
            iconst_0
            iconst_1
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.compareAndSet:(II)Z
            ifeq 13
        10: .line 236
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
            aload 2 /* u */
            invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
        11: .line 237
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.decrementAndGet:()I
            ifne 25
        12: .line 238
            iconst_1
            ireturn
        13: .line 241
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
            astore 3 /* q */
        start local 3 // io.reactivex.internal.fuseable.SimplePlainQueue q
        14: .line 242
            aload 3 /* q */
            ifnonnull 20
        15: .line 243
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            ldc 2147483647
            if_icmpne 18
        16: .line 244
            new io.reactivex.internal.queue.SpscLinkedArrayQueue
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.bufferSize:I
            invokespecial io.reactivex.internal.queue.SpscLinkedArrayQueue.<init>:(I)V
            astore 3 /* q */
        17: .line 245
            goto 19
        18: .line 246
      StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue
      StackMap stack:
            new io.reactivex.internal.queue.SpscArrayQueue
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
            astore 3 /* q */
        19: .line 248
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* q */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
        20: .line 251
      StackMap locals:
      StackMap stack:
            aload 3 /* q */
            aload 2 /* u */
            invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
            ifne 23
        21: .line 252
            aload 0 /* this */
            new java.lang.IllegalStateException
            dup
            ldc "Scalar queue full?!"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.onError:(Ljava/lang/Throwable;)V
        22: .line 253
            iconst_1
            ireturn
        23: .line 255
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.getAndIncrement:()I
            ifeq 25
        24: .line 256
            iconst_0
            ireturn
        end local 3 // io.reactivex.internal.fuseable.SimplePlainQueue q
        25: .line 259
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drainLoop:()V
        26: .line 260
            iconst_1
            ireturn
        end local 2 // java.lang.Object u
        end local 1 // java.util.concurrent.Callable value
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   27     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   27     1  value  Ljava/util/concurrent/Callable<+TU;>;
            1    2     2      u  TU;
            7   27     2      u  TU;
            3    7     3     ex  Ljava/lang/Throwable;
           14   25     3      q  Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: (Ljava/util/concurrent/Callable<+TU;>;)Z
    MethodParameters:
       Name  Flags
      value  

  void tryEmit(U, io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver<T, U>);
    descriptor: (Ljava/lang/Object;Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // java.lang.Object value
        start local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
         0: .line 264
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.get:()I
            ifne 4
            aload 0 /* this */
            iconst_0
            iconst_1
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.compareAndSet:(II)Z
            ifeq 4
         1: .line 265
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
            aload 1 /* value */
            invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
         2: .line 266
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.decrementAndGet:()I
            ifne 11
         3: .line 267
            return
         4: .line 270
      StackMap locals:
      StackMap stack:
            aload 2 /* inner */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 3 /* q */
        start local 3 // io.reactivex.internal.fuseable.SimpleQueue q
         5: .line 271
            aload 3 /* q */
            ifnonnull 8
         6: .line 272
            new io.reactivex.internal.queue.SpscLinkedArrayQueue
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.bufferSize:I
            invokespecial io.reactivex.internal.queue.SpscLinkedArrayQueue.<init>:(I)V
            astore 3 /* q */
         7: .line 273
            aload 2 /* inner */
            aload 3 /* q */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
         8: .line 275
      StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
      StackMap stack:
            aload 3 /* q */
            aload 1 /* value */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
            pop
         9: .line 276
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.getAndIncrement:()I
            ifeq 11
        10: .line 277
            return
        end local 3 // io.reactivex.internal.fuseable.SimpleQueue q
        11: .line 280
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drainLoop:()V
        12: .line 281
            return
        end local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
        end local 1 // java.lang.Object value
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   13     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0   13     1  value  TU;
            0   13     2  inner  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;
            5   11     3      q  Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
    Signature: (TU;Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;)V
    MethodParameters:
       Name  Flags
      value  
      inner  

  public void onError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
        start local 1 // java.lang.Throwable t
         0: .line 285
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
            ifeq 3
         1: .line 286
            aload 1 /* t */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
         2: .line 287
            return
         3: .line 289
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            aload 1 /* t */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            ifeq 7
         4: .line 290
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
         5: .line 291
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain:()V
         6: .line 292
            goto 8
         7: .line 293
      StackMap locals:
      StackMap stack:
            aload 1 /* t */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
         8: .line 295
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable t
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            0    9     1     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      t     

  public void onComplete();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 299
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
            ifeq 2
         1: .line 300
            return
         2: .line 302
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
         3: .line 303
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drain:()V
         4: .line 304
            return
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;

  public void dispose();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 308
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.cancelled:Z
            ifne 6
         1: .line 309
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.cancelled:Z
         2: .line 310
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.disposeAll:()Z
            ifeq 6
         3: .line 311
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            astore 1 /* ex */
        start local 1 // java.lang.Throwable ex
         4: .line 312
            aload 1 /* ex */
            ifnull 6
            aload 1 /* ex */
            getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
            if_acmpeq 6
         5: .line 313
            aload 1 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        end local 1 // java.lang.Throwable ex
         6: .line 317
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            4    6     1    ex  Ljava/lang/Throwable;

  public boolean isDisposed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 321
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.cancelled:Z
            ireturn
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;

  void drain();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 325
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.getAndIncrement:()I
            ifne 2
         1: .line 326
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.drainLoop:()V
         2: .line 328
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;

  void drainLoop();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=4, locals=18, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 331
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
            astore 1 /* child */
        start local 1 // io.reactivex.Observer child
         1: .line 332
            iconst_1
            istore 2 /* missed */
        start local 2 // int missed
         2: .line 334
      StackMap locals: io.reactivex.Observer int
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 4
         3: .line 335
            return
         4: .line 337
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
            astore 3 /* svq */
        start local 3 // io.reactivex.internal.fuseable.SimplePlainQueue svq
         5: .line 339
            aload 3 /* svq */
            ifnull 13
         6: .line 341
      StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 8
         7: .line 342
            return
         8: .line 345
      StackMap locals:
      StackMap stack:
            aload 3 /* svq */
            invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.poll:()Ljava/lang/Object;
            astore 4 /* o */
        start local 4 // java.lang.Object o
         9: .line 347
            aload 4 /* o */
            ifnonnull 11
        10: .line 348
            goto 13
        11: .line 351
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 1 /* child */
            aload 4 /* o */
            invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
        end local 4 // java.lang.Object o
        12: .line 340
            goto 6
        13: .line 355
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.done:Z
            istore 4 /* d */
        start local 4 // boolean d
        14: .line 356
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
            astore 3 /* svq */
        15: .line 357
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
            astore 5 /* inner */
        start local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] inner
        16: .line 358
            aload 5 /* inner */
            arraylength
            istore 6 /* n */
        start local 6 // int n
        17: .line 360
            iconst_0
            istore 7 /* nSources */
        start local 7 // int nSources
        18: .line 361
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            ldc 2147483647
            if_icmpeq 25
        19: .line 362
            aload 0 /* this */
            dup
            astore 8
            monitorenter
        20: .line 363
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.sources:Ljava/util/Queue;
            invokeinterface java.util.Queue.size:()I
            istore 7 /* nSources */
        21: .line 362
            aload 8
            monitorexit
        22: goto 25
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
      StackMap stack: java.lang.Throwable
        23: aload 8
            monitorexit
        24: athrow
        25: .line 367
      StackMap locals:
      StackMap stack:
            iload 4 /* d */
            ifeq 34
            aload 3 /* svq */
            ifnull 26
            aload 3 /* svq */
            invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.isEmpty:()Z
            ifeq 34
      StackMap locals:
      StackMap stack:
        26: iload 6 /* n */
            ifne 34
            iload 7 /* nSources */
            ifne 34
        27: .line 368
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            astore 8 /* ex */
        start local 8 // java.lang.Throwable ex
        28: .line 369
            aload 8 /* ex */
            getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
            if_acmpeq 33
        29: .line 370
            aload 8 /* ex */
            ifnonnull 32
        30: .line 371
            aload 1 /* child */
            invokeinterface io.reactivex.Observer.onComplete:()V
        31: .line 372
            goto 33
        32: .line 373
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 1 /* child */
            aload 8 /* ex */
            invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
        33: .line 376
      StackMap locals:
      StackMap stack:
            return
        end local 8 // java.lang.Throwable ex
        34: .line 379
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 8 /* innerCompleted */
        start local 8 // int innerCompleted
        35: .line 380
            iload 6 /* n */
            ifeq 95
        36: .line 381
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastId:J
            lstore 9 /* startId */
        start local 9 // long startId
        37: .line 382
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastIndex:I
            istore 11 /* index */
        start local 11 // int index
        38: .line 384
            iload 6 /* n */
            iload 11 /* index */
            if_icmple 39
            aload 5 /* inner */
            iload 11 /* index */
            aaload
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.id:J
            lload 9 /* startId */
            lcmp
            ifeq 54
        39: .line 385
      StackMap locals: int long int
      StackMap stack:
            iload 6 /* n */
            iload 11 /* index */
            if_icmpgt 41
        40: .line 386
            iconst_0
            istore 11 /* index */
        41: .line 388
      StackMap locals:
      StackMap stack:
            iload 11 /* index */
            istore 12 /* j */
        start local 12 // int j
        42: .line 389
            iconst_0
            istore 13 /* i */
        start local 13 // int i
        43: goto 50
        44: .line 390
      StackMap locals: int int
      StackMap stack:
            aload 5 /* inner */
            iload 12 /* j */
            aaload
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.id:J
            lload 9 /* startId */
            lcmp
            ifne 46
        45: .line 391
            goto 51
        46: .line 393
      StackMap locals:
      StackMap stack:
            iinc 12 /* j */ 1
        47: .line 394
            iload 12 /* j */
            iload 6 /* n */
            if_icmpne 49
        48: .line 395
            iconst_0
            istore 12 /* j */
        49: .line 389
      StackMap locals:
      StackMap stack:
            iinc 13 /* i */ 1
      StackMap locals:
      StackMap stack:
        50: iload 13 /* i */
            iload 6 /* n */
            if_icmplt 44
        end local 13 // int i
        51: .line 398
      StackMap locals:
      StackMap stack:
            iload 12 /* j */
            istore 11 /* index */
        52: .line 399
            aload 0 /* this */
            iload 12 /* j */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastIndex:I
        53: .line 400
            aload 0 /* this */
            aload 5 /* inner */
            iload 12 /* j */
            aaload
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.id:J
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastId:J
        end local 12 // int j
        54: .line 403
      StackMap locals:
      StackMap stack:
            iload 11 /* index */
            istore 12 /* j */
        start local 12 // int j
        55: .line 405
            iconst_0
            istore 13 /* i */
        start local 13 // int i
        56: goto 92
        57: .line 406
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 59
        58: .line 407
            return
        59: .line 411
      StackMap locals:
      StackMap stack:
            aload 5 /* inner */
            iload 12 /* j */
            aaload
            astore 14 /* is */
        start local 14 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver is
        60: .line 412
            aload 14 /* is */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 15 /* q */
        start local 15 // io.reactivex.internal.fuseable.SimpleQueue q
        61: .line 413
            aload 15 /* q */
            ifnull 81
        62: .line 417
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver io.reactivex.internal.fuseable.SimpleQueue
      StackMap stack:
            aload 15 /* q */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 16 /* o */
        start local 16 // java.lang.Object o
        63: .line 418
            goto 76
        end local 16 // java.lang.Object o
      StackMap locals:
      StackMap stack: java.lang.Throwable
        64: astore 17 /* ex */
        start local 17 // java.lang.Throwable ex
        65: .line 419
            aload 17 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        66: .line 420
            aload 14 /* is */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.dispose:()V
        67: .line 421
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            aload 17 /* ex */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            pop
        68: .line 422
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 70
        69: .line 423
            return
        70: .line 425
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int long int int int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver io.reactivex.internal.fuseable.SimpleQueue top java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            aload 14 /* is */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.removeInner:(Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)V
        71: .line 426
            iinc 8 /* innerCompleted */ 1
        72: .line 427
            iinc 12 /* j */ 1
        73: .line 428
            iload 12 /* j */
            iload 6 /* n */
            if_icmpne 91
        74: .line 429
            iconst_0
            istore 12 /* j */
        75: .line 431
            goto 91
        end local 17 // java.lang.Throwable ex
        start local 16 // java.lang.Object o
        76: .line 433
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int long int int int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver io.reactivex.internal.fuseable.SimpleQueue java.lang.Object
      StackMap stack:
            aload 16 /* o */
            ifnonnull 78
        77: .line 434
            goto 81
        78: .line 437
      StackMap locals:
      StackMap stack:
            aload 1 /* child */
            aload 16 /* o */
            invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
        79: .line 439
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 62
        80: .line 440
            return
        end local 16 // java.lang.Object o
        81: .line 445
      StackMap locals:
      StackMap stack:
            aload 14 /* is */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.done:Z
            istore 16 /* innerDone */
        start local 16 // boolean innerDone
        82: .line 446
            aload 14 /* is */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 17 /* innerQueue */
        start local 17 // io.reactivex.internal.fuseable.SimpleQueue innerQueue
        83: .line 447
            iload 16 /* innerDone */
            ifeq 88
            aload 17 /* innerQueue */
            ifnull 84
            aload 17 /* innerQueue */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
            ifeq 88
        84: .line 448
      StackMap locals: int io.reactivex.internal.fuseable.SimpleQueue
      StackMap stack:
            aload 0 /* this */
            aload 14 /* is */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.removeInner:(Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;)V
        85: .line 449
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.checkTerminate:()Z
            ifeq 87
        86: .line 450
            return
        87: .line 452
      StackMap locals:
      StackMap stack:
            iinc 8 /* innerCompleted */ 1
        88: .line 455
      StackMap locals:
      StackMap stack:
            iinc 12 /* j */ 1
        89: .line 456
            iload 12 /* j */
            iload 6 /* n */
            if_icmpne 91
        90: .line 457
            iconst_0
            istore 12 /* j */
        end local 17 // io.reactivex.internal.fuseable.SimpleQueue innerQueue
        end local 16 // boolean innerDone
        end local 15 // io.reactivex.internal.fuseable.SimpleQueue q
        end local 14 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver is
        91: .line 405
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int long int int int
      StackMap stack:
            iinc 13 /* i */ 1
      StackMap locals:
      StackMap stack:
        92: iload 13 /* i */
            iload 6 /* n */
            if_icmplt 57
        end local 13 // int i
        93: .line 460
            aload 0 /* this */
            iload 12 /* j */
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastIndex:I
        94: .line 461
            aload 0 /* this */
            aload 5 /* inner */
            iload 12 /* j */
            aaload
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.id:J
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.lastId:J
        end local 12 // int j
        end local 11 // int index
        end local 9 // long startId
        95: .line 464
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int
      StackMap stack:
            iload 8 /* innerCompleted */
            ifeq 111
        96: .line 465
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.maxConcurrency:I
            ldc 2147483647
            if_icmpeq 2
        97: .line 466
            goto 109
        98: .line 468
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            astore 10
            monitorenter
        99: .line 469
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.sources:Ljava/util/Queue;
            invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
            checkcast io.reactivex.ObservableSource
            astore 9 /* p */
        start local 9 // io.reactivex.ObservableSource p
       100: .line 470
            aload 9 /* p */
            ifnonnull 104
       101: .line 471
            aload 0 /* this */
            dup
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
            iconst_1
            isub
            putfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.wip:I
       102: .line 472
            aload 10
            monitorexit
       103: goto 109
       104: .line 468
      StackMap locals: io.reactivex.ObservableSource io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
      StackMap stack:
            aload 10
            monitorexit
       105: goto 108
        end local 9 // io.reactivex.ObservableSource p
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int top io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver
      StackMap stack: java.lang.Throwable
       106: aload 10
            monitorexit
       107: athrow
        start local 9 // io.reactivex.ObservableSource p
       108: .line 475
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.Observer int io.reactivex.internal.fuseable.SimplePlainQueue int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] int int int io.reactivex.ObservableSource
      StackMap stack:
            aload 0 /* this */
            aload 9 /* p */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.subscribeInner:(Lio/reactivex/ObservableSource;)V
        end local 9 // io.reactivex.ObservableSource p
       109: .line 466
      StackMap locals:
      StackMap stack:
            iload 8 /* innerCompleted */
            iinc 8 /* innerCompleted */ -1
            ifne 98
       110: .line 478
            goto 2
       111: .line 480
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 2 /* missed */
            ineg
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.addAndGet:(I)I
            istore 2 /* missed */
       112: .line 481
            iload 2 /* missed */
            ifne 2
        end local 8 // int innerCompleted
        end local 7 // int nSources
        end local 6 // int n
        end local 5 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] inner
        end local 4 // boolean d
        end local 3 // io.reactivex.internal.fuseable.SimplePlainQueue svq
       113: .line 485
            return
        end local 2 // int missed
        end local 1 // io.reactivex.Observer child
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0  114     0            this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            1  114     1           child  Lio/reactivex/Observer<-TU;>;
            2  114     2          missed  I
            5  113     3             svq  Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;
            9   12     4               o  TU;
           14  113     4               d  Z
           16  113     5           inner  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
           17  113     6               n  I
           18  113     7        nSources  I
           28   34     8              ex  Ljava/lang/Throwable;
           35  113     8  innerCompleted  I
           37   95     9         startId  J
           38   95    11           index  I
           42   54    12               j  I
           43   51    13               i  I
           55   95    12               j  I
           56   93    13               i  I
           60   91    14              is  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<TT;TU;>;
           61   91    15               q  Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
           63   64    16               o  TU;
           76   81    16               o  TU;
           65   76    17              ex  Ljava/lang/Throwable;
           82   91    16       innerDone  Z
           83   91    17      innerQueue  Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
          100  106     9               p  Lio/reactivex/ObservableSource<+TU;>;
          108  109     9               p  Lio/reactivex/ObservableSource<+TU;>;
      Exception table:
        from    to  target  type
          20    22      23  any
          23    24      23  any
          62    63      64  Class java.lang.Throwable
          99   103     106  any
         104   105     106  any
         106   107     106  any

  boolean checkTerminate();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 488
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.cancelled:Z
            ifeq 2
         1: .line 489
            iconst_1
            ireturn
         2: .line 491
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            astore 1 /* e */
        start local 1 // java.lang.Throwable e
         3: .line 492
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.delayErrors:Z
            ifne 9
            aload 1 /* e */
            ifnull 9
         4: .line 493
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.disposeAll:()Z
            pop
         5: .line 494
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.errors:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            astore 1 /* e */
         6: .line 495
            aload 1 /* e */
            getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
            if_acmpeq 8
         7: .line 496
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.downstream:Lio/reactivex/Observer;
            aload 1 /* e */
            invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
         8: .line 498
      StackMap locals: java.lang.Throwable
      StackMap stack:
            iconst_1
            ireturn
         9: .line 500
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 1 // java.lang.Throwable e
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            3   10     1     e  Ljava/lang/Throwable;

  boolean disposeAll();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=2, locals=6, args_size=1
        start local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
         0: .line 504
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.upstream:Lio/reactivex/disposables/Disposable;
            invokeinterface io.reactivex.disposables.Disposable.dispose:()V
         1: .line 505
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
            astore 1 /* a */
        start local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
         2: .line 506
            aload 1 /* a */
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.CANCELLED:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            if_acmpeq 11
         3: .line 507
            aload 0 /* this */
            getfield io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.observers:Ljava/util/concurrent/atomic/AtomicReference;
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.CANCELLED:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
            astore 1 /* a */
         4: .line 508
            aload 1 /* a */
            getstatic io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver.CANCELLED:[Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            if_acmpeq 11
         5: .line 509
            aload 1 /* a */
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 9
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] top int int io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
      StackMap stack:
         6: aload 5
            iload 3
            aaload
            astore 2 /* inner */
        start local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
         7: .line 510
            aload 2 /* inner */
            invokevirtual io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver.dispose:()V
        end local 2 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver inner
         8: .line 509
            iinc 3 1
      StackMap locals:
      StackMap stack:
         9: iload 3
            iload 4
            if_icmplt 6
        10: .line 512
            iconst_1
            ireturn
        11: .line 515
      StackMap locals: io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[]
      StackMap stack:
            iconst_0
            ireturn
        end local 1 // io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver[] a
        end local 0 // io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   12     0   this  Lio/reactivex/internal/operators/observable/ObservableFlatMap$MergeObserver<TT;TU;>;
            2   12     1      a  [Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver;
            7    8     2  inner  Lio/reactivex/internal/operators/observable/ObservableFlatMap$InnerObserver<**>;
}
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/disposables/Disposable;Lio/reactivex/Observer<TT;>;
SourceFile: "ObservableFlatMap.java"
NestHost: io.reactivex.internal.operators.observable.ObservableFlatMap
InnerClasses:
  final InnerObserver = io.reactivex.internal.operators.observable.ObservableFlatMap$InnerObserver of io.reactivex.internal.operators.observable.ObservableFlatMap
  final MergeObserver = io.reactivex.internal.operators.observable.ObservableFlatMap$MergeObserver of io.reactivex.internal.operators.observable.ObservableFlatMap