io.reactivex.rxjava2/rxjava/2.2.11 : io/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator.class

FlowableSequenceEqualSingle$EqualCoordinator
https://github.com/ReactiveX/RxJava: Reactive Extensions for Java
The Apache Software License, Version 2.0
David Karnok
final class io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator<T> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.disposables.Disposable, io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualCoordinatorHelper
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator
  super_class: java.util.concurrent.atomic.AtomicInteger
{
  private static final long serialVersionUID;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: -6178010334400373240

  final io.reactivex.SingleObserver<? super java.lang.Boolean> downstream;
    descriptor: Lio/reactivex/SingleObserver;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/SingleObserver<-Ljava/lang/Boolean;>;

  final io.reactivex.functions.BiPredicate<? super T, ? super T> comparer;
    descriptor: Lio/reactivex/functions/BiPredicate;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/functions/BiPredicate<-TT;-TT;>;

  final io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber<T> first;
    descriptor: Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber<TT;>;

  final io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber<T> second;
    descriptor: Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber<TT;>;

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

  T v1;
    descriptor: Ljava/lang/Object;
    flags: (0x0000) 
    Signature: TT;

  T v2;
    descriptor: Ljava/lang/Object;
    flags: (0x0000) 
    Signature: TT;

  void <init>(io.reactivex.SingleObserver<? super java.lang.Boolean>, int, io.reactivex.functions.BiPredicate<? super T, ? super T>);
    descriptor: (Lio/reactivex/SingleObserver;ILio/reactivex/functions/BiPredicate;)V
    flags: (0x0000) 
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
        start local 1 // io.reactivex.SingleObserver actual
        start local 2 // int prefetch
        start local 3 // io.reactivex.functions.BiPredicate comparer
         0: .line 76
            aload 0 /* this */
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
         1: .line 77
            aload 0 /* this */
            aload 1 /* actual */
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
         2: .line 78
            aload 0 /* this */
            aload 3 /* comparer */
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.comparer:Lio/reactivex/functions/BiPredicate;
         3: .line 79
            aload 0 /* this */
            new io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber
            dup
            aload 0 /* this */
            iload 2 /* prefetch */
            invokespecial io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.<init>:(Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualCoordinatorHelper;I)V
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
         4: .line 80
            aload 0 /* this */
            new io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber
            dup
            aload 0 /* this */
            iload 2 /* prefetch */
            invokespecial io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.<init>:(Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualCoordinatorHelper;I)V
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
         5: .line 81
            aload 0 /* this */
            new io.reactivex.internal.util.AtomicThrowable
            dup
            invokespecial io.reactivex.internal.util.AtomicThrowable.<init>:()V
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
         6: .line 82
            return
        end local 3 // io.reactivex.functions.BiPredicate comparer
        end local 2 // int prefetch
        end local 1 // io.reactivex.SingleObserver actual
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;
            0    7     1    actual  Lio/reactivex/SingleObserver<-Ljava/lang/Boolean;>;
            0    7     2  prefetch  I
            0    7     3  comparer  Lio/reactivex/functions/BiPredicate<-TT;-TT;>;
    Signature: (Lio/reactivex/SingleObserver<-Ljava/lang/Boolean;>;ILio/reactivex/functions/BiPredicate<-TT;-TT;>;)V
    MethodParameters:
          Name  Flags
      actual    
      prefetch  
      comparer  

  void subscribe(org.reactivestreams.Publisher<? extends T>, org.reactivestreams.Publisher<? extends T>);
    descriptor: (Lorg/reactivestreams/Publisher;Lorg/reactivestreams/Publisher;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
        start local 1 // org.reactivestreams.Publisher source1
        start local 2 // org.reactivestreams.Publisher source2
         0: .line 85
            aload 1 /* source1 */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
         1: .line 86
            aload 2 /* source2 */
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
         2: .line 87
            return
        end local 2 // org.reactivestreams.Publisher source2
        end local 1 // org.reactivestreams.Publisher source1
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;
            0    3     1  source1  Lorg/reactivestreams/Publisher<+TT;>;
            0    3     2  source2  Lorg/reactivestreams/Publisher<+TT;>;
    Signature: (Lorg/reactivestreams/Publisher<+TT;>;Lorg/reactivestreams/Publisher<+TT;>;)V
    MethodParameters:
         Name  Flags
      source1  
      source2  

  public void dispose();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
         0: .line 91
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.cancel:()V
         1: .line 92
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.cancel:()V
         2: .line 93
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.getAndIncrement:()I
            ifne 5
         3: .line 94
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         4: .line 95
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         5: .line 97
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;

  public boolean isDisposed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
         0: .line 101
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.get:()Ljava/lang/Object;
            getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
            if_acmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;

  void cancelAndClear();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
         0: .line 105
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.cancel:()V
         1: .line 106
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         2: .line 107
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.cancel:()V
         3: .line 108
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         4: .line 109
            return
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;

  public void drain();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=13, args_size=1
        start local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
         0: .line 113
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.getAndIncrement:()I
            ifeq 2
         1: .line 114
            return
         2: .line 117
      StackMap locals:
      StackMap stack:
            iconst_1
            istore 1 /* missed */
        start local 1 // int missed
         3: .line 120
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 2 /* q1 */
        start local 2 // io.reactivex.internal.fuseable.SimpleQueue q1
         4: .line 121
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
            astore 3 /* q2 */
        start local 3 // io.reactivex.internal.fuseable.SimpleQueue q2
         5: .line 123
            aload 2 /* q1 */
            ifnull 71
            aload 3 /* q2 */
            ifnull 71
         6: .line 125
      StackMap locals: io.reactivex.internal.fuseable.SimpleQueue io.reactivex.internal.fuseable.SimpleQueue
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.isDisposed:()Z
            ifeq 10
         7: .line 126
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         8: .line 127
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
         9: .line 128
            return
        10: .line 131
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            astore 4 /* ex */
        start local 4 // java.lang.Throwable ex
        11: .line 132
            aload 4 /* ex */
            ifnull 15
        12: .line 133
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        13: .line 135
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
        14: .line 136
            return
        15: .line 139
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.done:Z
            istore 5 /* d1 */
        start local 5 // boolean d1
        16: .line 141
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v1:Ljava/lang/Object;
            astore 6 /* a */
        start local 6 // java.lang.Object a
        17: .line 142
            aload 6 /* a */
            ifnonnull 27
        18: .line 144
            aload 2 /* q1 */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 6 /* a */
        19: .line 145
            goto 26
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator int io.reactivex.internal.fuseable.SimpleQueue io.reactivex.internal.fuseable.SimpleQueue java.lang.Throwable int java.lang.Object
      StackMap stack: java.lang.Throwable
        20: astore 7 /* exc */
        start local 7 // java.lang.Throwable exc
        21: .line 146
            aload 7 /* exc */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        22: .line 147
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        23: .line 148
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            aload 7 /* exc */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            pop
        24: .line 149
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
        25: .line 150
            return
        end local 7 // java.lang.Throwable exc
        26: .line 152
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 6 /* a */
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v1:Ljava/lang/Object;
        27: .line 154
      StackMap locals:
      StackMap stack:
            aload 6 /* a */
            ifnonnull 28
            iconst_1
            goto 29
      StackMap locals:
      StackMap stack:
        28: iconst_0
      StackMap locals:
      StackMap stack: int
        29: istore 7 /* e1 */
        start local 7 // boolean e1
        30: .line 156
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.done:Z
            istore 8 /* d2 */
        start local 8 // boolean d2
        31: .line 157
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v2:Ljava/lang/Object;
            astore 9 /* b */
        start local 9 // java.lang.Object b
        32: .line 158
            aload 9 /* b */
            ifnonnull 42
        33: .line 160
            aload 3 /* q2 */
            invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
            astore 9 /* b */
        34: .line 161
            goto 41
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator int io.reactivex.internal.fuseable.SimpleQueue io.reactivex.internal.fuseable.SimpleQueue java.lang.Throwable int java.lang.Object int int java.lang.Object
      StackMap stack: java.lang.Throwable
        35: astore 10 /* exc */
        start local 10 // java.lang.Throwable exc
        36: .line 162
            aload 10 /* exc */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        37: .line 163
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        38: .line 164
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            aload 10 /* exc */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            pop
        39: .line 165
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
        40: .line 166
            return
        end local 10 // java.lang.Throwable exc
        41: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 9 /* b */
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v2:Ljava/lang/Object;
        42: .line 171
      StackMap locals:
      StackMap stack:
            aload 9 /* b */
            ifnonnull 43
            iconst_1
            goto 44
      StackMap locals:
      StackMap stack:
        43: iconst_0
      StackMap locals:
      StackMap stack: int
        44: istore 10 /* e2 */
        start local 10 // boolean e2
        45: .line 173
            iload 5 /* d1 */
            ifeq 48
            iload 8 /* d2 */
            ifeq 48
            iload 7 /* e1 */
            ifeq 48
            iload 10 /* e2 */
            ifeq 48
        46: .line 174
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.reactivex.SingleObserver.onSuccess:(Ljava/lang/Object;)V
        47: .line 175
            return
        48: .line 177
      StackMap locals: int
      StackMap stack:
            iload 5 /* d1 */
            ifeq 52
            iload 8 /* d2 */
            ifeq 52
            iload 7 /* e1 */
            iload 10 /* e2 */
            if_icmpeq 52
        49: .line 178
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        50: .line 179
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            iconst_0
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.reactivex.SingleObserver.onSuccess:(Ljava/lang/Object;)V
        51: .line 180
            return
        52: .line 183
      StackMap locals:
      StackMap stack:
            iload 7 /* e1 */
            ifne 80
            iload 10 /* e2 */
            ifeq 54
        53: .line 184
            goto 80
        54: .line 190
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.comparer:Lio/reactivex/functions/BiPredicate;
            aload 6 /* a */
            aload 9 /* b */
            invokeinterface io.reactivex.functions.BiPredicate.test:(Ljava/lang/Object;Ljava/lang/Object;)Z
            istore 11 /* c */
        start local 11 // boolean c
        55: .line 191
            goto 62
        end local 11 // boolean c
      StackMap locals:
      StackMap stack: java.lang.Throwable
        56: astore 12 /* exc */
        start local 12 // java.lang.Throwable exc
        57: .line 192
            aload 12 /* exc */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        58: .line 193
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        59: .line 194
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            aload 12 /* exc */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            pop
        60: .line 195
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
        61: .line 196
            return
        end local 12 // java.lang.Throwable exc
        start local 11 // boolean c
        62: .line 199
      StackMap locals: int
      StackMap stack:
            iload 11 /* c */
            ifne 66
        63: .line 200
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        64: .line 201
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            iconst_0
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.reactivex.SingleObserver.onSuccess:(Ljava/lang/Object;)V
        65: .line 202
            return
        66: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v1:Ljava/lang/Object;
        67: .line 206
            aload 0 /* this */
            aconst_null
            putfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.v2:Ljava/lang/Object;
        68: .line 208
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.request:()V
        69: .line 209
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.request:()V
        end local 11 // boolean c
        end local 10 // boolean e2
        end local 9 // java.lang.Object b
        end local 8 // boolean d2
        end local 7 // boolean e1
        end local 6 // java.lang.Object a
        end local 5 // boolean d1
        end local 4 // java.lang.Throwable ex
        70: .line 124
            goto 6
        71: .line 213
      StackMap locals: io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator int io.reactivex.internal.fuseable.SimpleQueue io.reactivex.internal.fuseable.SimpleQueue
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.isDisposed:()Z
            ifeq 75
        72: .line 214
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.first:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
        73: .line 215
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.second:Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualSubscriber;
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber.clear:()V
        74: .line 216
            return
        75: .line 219
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            astore 4 /* ex */
        start local 4 // java.lang.Throwable ex
        76: .line 220
            aload 4 /* ex */
            ifnull 80
        77: .line 221
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.cancelAndClear:()V
        78: .line 223
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.downstream:Lio/reactivex/SingleObserver;
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
            invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
        79: .line 224
            return
        end local 4 // java.lang.Throwable ex
        80: .line 228
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* missed */
            ineg
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.addAndGet:(I)I
            istore 1 /* missed */
        81: .line 229
            iload 1 /* missed */
            ifne 3
        end local 3 // io.reactivex.internal.fuseable.SimpleQueue q2
        end local 2 // io.reactivex.internal.fuseable.SimpleQueue q1
        82: .line 233
            return
        end local 1 // int missed
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   83     0    this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;
            3   83     1  missed  I
            4   82     2      q1  Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
            5   82     3      q2  Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
           11   70     4      ex  Ljava/lang/Throwable;
           16   70     5      d1  Z
           17   70     6       a  TT;
           21   26     7     exc  Ljava/lang/Throwable;
           30   70     7      e1  Z
           31   70     8      d2  Z
           32   70     9       b  TT;
           36   41    10     exc  Ljava/lang/Throwable;
           45   70    10      e2  Z
           55   56    11       c  Z
           62   70    11       c  Z
           57   62    12     exc  Ljava/lang/Throwable;
           76   80     4      ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          18    19      20  Class java.lang.Throwable
          33    34      35  Class java.lang.Throwable
          54    55      56  Class java.lang.Throwable

  public void innerError(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.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
        start local 1 // java.lang.Throwable t
         0: .line 237
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.error:Lio/reactivex/internal/util/AtomicThrowable;
            aload 1 /* t */
            invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
            ifeq 3
         1: .line 238
            aload 0 /* this */
            invokevirtual io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator.drain:()V
         2: .line 239
            goto 4
         3: .line 240
      StackMap locals:
      StackMap stack:
            aload 1 /* t */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
         4: .line 242
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable t
        end local 0 // io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator<TT;>;
            0    5     1     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      t     
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/disposables/Disposable;Lio/reactivex/internal/operators/flowable/FlowableSequenceEqual$EqualCoordinatorHelper;
SourceFile: "FlowableSequenceEqualSingle.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle
InnerClasses:
  abstract EqualCoordinatorHelper = io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualCoordinatorHelper of io.reactivex.internal.operators.flowable.FlowableSequenceEqual
  final EqualSubscriber = io.reactivex.internal.operators.flowable.FlowableSequenceEqual$EqualSubscriber of io.reactivex.internal.operators.flowable.FlowableSequenceEqual
  final EqualCoordinator = io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle$EqualCoordinator of io.reactivex.internal.operators.flowable.FlowableSequenceEqualSingle
/

io.reactivex.rxjava2/ rxjava/ 2.2.11/ io/reactivex/internal/operators/flowable/FlowableSequenceEqualSingle$EqualCoordinator.class
