final class io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<T, R> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.FlowableSubscriber<T>, org.reactivestreams.Subscription
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber
super_class: java.util.concurrent.atomic.AtomicInteger
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -9140123220065488293
final org.reactivestreams.Subscriber<? super R> downstream;
descriptor: Lorg/reactivestreams/Subscriber;
flags: (0x0010) ACC_FINAL
Signature: Lorg/reactivestreams/Subscriber<-TR;>;
final io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends R>> mapper;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;
final int prefetch;
descriptor: I
flags: (0x0010) ACC_FINAL
final java.util.concurrent.atomic.AtomicLong requested;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0010) ACC_FINAL
final io.reactivex.internal.util.AtomicThrowable errors;
descriptor: Lio/reactivex/internal/util/AtomicThrowable;
flags: (0x0010) ACC_FINAL
final io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver<R> inner;
descriptor: Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver<TR;>;
final io.reactivex.internal.fuseable.SimplePlainQueue<T> queue;
descriptor: Lio/reactivex/internal/fuseable/SimplePlainQueue;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/internal/fuseable/SimplePlainQueue<TT;>;
final io.reactivex.internal.util.ErrorMode errorMode;
descriptor: Lio/reactivex/internal/util/ErrorMode;
flags: (0x0010) ACC_FINAL
org.reactivestreams.Subscription upstream;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile boolean cancelled;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
long emitted;
descriptor: J
flags: (0x0000)
int consumed;
descriptor: I
flags: (0x0000)
R item;
descriptor: Ljava/lang/Object;
flags: (0x0000)
Signature: TR;
volatile int state;
descriptor: I
flags: (0x0040) ACC_VOLATILE
static final int STATE_INACTIVE;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 0
static final int STATE_ACTIVE;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 1
static final int STATE_RESULT_VALUE;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 2
void <init>(org.reactivestreams.Subscriber<? super R>, io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends R>>, int, io.reactivex.internal.util.ErrorMode);
descriptor: (Lorg/reactivestreams/Subscriber;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
aload 1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
2: aload 0
aload 2
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.mapper:Lio/reactivex/functions/Function;
3: aload 0
iload 3
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.prefetch:I
4: aload 0
aload 4
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errorMode:Lio/reactivex/internal/util/ErrorMode;
5: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
6: aload 0
new io.reactivex.internal.util.AtomicThrowable
dup
invokespecial io.reactivex.internal.util.AtomicThrowable.<init>:()V
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errors:Lio/reactivex/internal/util/AtomicThrowable;
7: aload 0
new io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver
dup
aload 0
invokespecial io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver.<init>:(Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber;)V
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.inner:Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver;
8: aload 0
new io.reactivex.internal.queue.SpscArrayQueue
dup
iload 3
invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
9: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 10 1 downstream Lorg/reactivestreams/Subscriber<-TR;>;
0 10 2 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;
0 10 3 prefetch I
0 10 4 errorMode Lio/reactivex/internal/util/ErrorMode;
Signature: (Lorg/reactivestreams/Subscriber<-TR;>;Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;ILio/reactivex/internal/util/ErrorMode;)V
MethodParameters:
Name Flags
downstream
mapper
prefetch
errorMode
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 4
1: aload 0
aload 1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
2: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 0
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
3: aload 1
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.prefetch:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 5 1 s Lorg/reactivestreams/Subscription;
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
aload 1
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
ifne 4
1: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
2: aload 0
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "queue full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.onError:(Ljava/lang/Throwable;)V
3: return
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 6 1 t TT;
Signature: (TT;)V
MethodParameters:
Name Flags
t
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 start local 1 0: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errors:Lio/reactivex/internal/util/AtomicThrowable;
aload 1
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
ifeq 6
1: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errorMode:Lio/reactivex/internal/util/ErrorMode;
getstatic io.reactivex.internal.util.ErrorMode.IMMEDIATE:Lio/reactivex/internal/util/ErrorMode;
if_acmpne 3
2: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.inner:Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver;
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver.dispose:()V
3: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.done:Z
4: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 8 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 0: aload 0
iconst_1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.done:Z
1: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
public void request(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokestatic io.reactivex.internal.util.BackpressureHelper.add:(Ljava/util/concurrent/atomic/AtomicLong;J)J
pop2
1: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 3 1 n J
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.cancelled:Z
1: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
2: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.inner:Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver;
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver.dispose:()V
3: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.getAndIncrement:()I
ifne 6
4: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
5: aload 0
aconst_null
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
void innerSuccess();
descriptor: (Ljava/lang/Object;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
1: aload 0
iconst_2
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
2: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 4 1 item TR;
Signature: (TR;)V
MethodParameters:
Name Flags
item
void innerComplete();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
1: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
void innerError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errors:Lio/reactivex/internal/util/AtomicThrowable;
aload 1
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
ifeq 6
1: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errorMode:Lio/reactivex/internal/util/ErrorMode;
getstatic io.reactivex.internal.util.ErrorMode.END:Lio/reactivex/internal/util/ErrorMode;
if_acmpeq 3
2: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
3: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
4: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain:()V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
0 8 1 ex Ljava/lang/Throwable;
MethodParameters:
Name Flags
ex
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=15, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.getAndIncrement:()I
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
iconst_1
istore 1
start local 1 3: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
astore 2
start local 2 4: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errorMode:Lio/reactivex/internal/util/ErrorMode;
astore 3
start local 3 5: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 4
start local 4 6: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.errors:Lio/reactivex/internal/util/AtomicThrowable;
astore 5
start local 5 7: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
astore 6
start local 6 8: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.prefetch:I
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.prefetch:I
iconst_1
ishr
isub
istore 7
start local 7 9: StackMap locals: io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber int org.reactivestreams.Subscriber io.reactivex.internal.util.ErrorMode io.reactivex.internal.fuseable.SimplePlainQueue io.reactivex.internal.util.AtomicThrowable java.util.concurrent.atomic.AtomicLong int
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.cancelled:Z
ifeq 13
10: aload 4
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
11: aload 0
aconst_null
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
12: goto 65
13: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
istore 8
start local 8 14: aload 5
invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
ifnull 22
15: aload 3
getstatic io.reactivex.internal.util.ErrorMode.IMMEDIATE:Lio/reactivex/internal/util/ErrorMode;
if_acmpeq 17
16: aload 3
getstatic io.reactivex.internal.util.ErrorMode.BOUNDARY:Lio/reactivex/internal/util/ErrorMode;
if_acmpne 22
iload 8
ifne 22
17: StackMap locals: int
StackMap stack:
aload 4
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
18: aload 0
aconst_null
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
19: aload 5
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 9
start local 9 20: aload 2
aload 9
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
21: return
end local 9 22: StackMap locals:
StackMap stack:
iload 8
ifne 56
23: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.done:Z
istore 9
start local 9 24: aload 4
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.poll:()Ljava/lang/Object;
astore 10
start local 10 25: aload 10
ifnonnull 26
iconst_1
goto 27
StackMap locals: int java.lang.Object
StackMap stack:
26: iconst_0
StackMap locals:
StackMap stack: int
27: istore 11
start local 11 28: iload 9
ifeq 35
iload 11
ifeq 35
29: aload 5
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 12
start local 12 30: aload 12
ifnonnull 33
31: aload 2
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
32: goto 34
33: StackMap locals: int java.lang.Throwable
StackMap stack:
aload 2
aload 12
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
34: StackMap locals:
StackMap stack:
return
end local 12 35: StackMap locals:
StackMap stack:
iload 11
ifeq 37
36: goto 65
37: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.consumed:I
iconst_1
iadd
istore 12
start local 12 38: iload 12
iload 7
if_icmpne 42
39: aload 0
iconst_0
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.consumed:I
40: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
iload 7
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
41: goto 43
42: StackMap locals: int
StackMap stack:
aload 0
iload 12
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.consumed:I
43: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.mapper:Lio/reactivex/functions/Function;
aload 10
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.MaybeSource
ldc "The mapper returned a null MaybeSource"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.MaybeSource
astore 13
start local 13 44: goto 53
end local 13 StackMap locals:
StackMap stack: java.lang.Throwable
45: astore 14
start local 14 46: aload 14
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
47: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
48: aload 4
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
49: aload 5
aload 14
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
pop
50: aload 5
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 14
51: aload 2
aload 14
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
52: return
end local 14 start local 13 53: StackMap locals: io.reactivex.MaybeSource
StackMap stack:
aload 0
iconst_1
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
54: aload 13
aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.inner:Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver;
invokeinterface io.reactivex.MaybeSource.subscribe:(Lio/reactivex/MaybeObserver;)V
55: goto 65
end local 13 end local 12 end local 11 end local 10 end local 9 56: StackMap locals: io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber int org.reactivestreams.Subscriber io.reactivex.internal.util.ErrorMode io.reactivex.internal.fuseable.SimplePlainQueue io.reactivex.internal.util.AtomicThrowable java.util.concurrent.atomic.AtomicLong int int
StackMap stack:
iload 8
iconst_2
if_icmpne 65
57: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.emitted:J
lstore 9
start local 9 58: lload 9
aload 6
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lcmp
ifeq 65
59: aload 0
getfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
astore 11
start local 11 60: aload 0
aconst_null
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.item:Ljava/lang/Object;
61: aload 2
aload 11
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
62: aload 0
lload 9
lconst_1
ladd
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.emitted:J
63: aload 0
iconst_0
putfield io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.state:I
end local 11 end local 9 end local 8 64: goto 9
65: StackMap locals:
StackMap stack:
aload 0
iload 1
ineg
invokevirtual io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.addAndGet:(I)I
istore 1
66: iload 1
ifne 9
67: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 68 0 this Lio/reactivex/internal/operators/mixed/FlowableConcatMapMaybe$ConcatMapMaybeSubscriber<TT;TR;>;
3 68 1 missed I
4 68 2 downstream Lorg/reactivestreams/Subscriber<-TR;>;
5 68 3 errorMode Lio/reactivex/internal/util/ErrorMode;
6 68 4 queue Lio/reactivex/internal/fuseable/SimplePlainQueue<TT;>;
7 68 5 errors Lio/reactivex/internal/util/AtomicThrowable;
8 68 6 requested Ljava/util/concurrent/atomic/AtomicLong;
9 68 7 limit I
14 64 8 s I
20 22 9 ex Ljava/lang/Throwable;
24 56 9 d Z
25 56 10 v TT;
28 56 11 empty Z
30 35 12 ex Ljava/lang/Throwable;
38 56 12 c I
44 45 13 ms Lio/reactivex/MaybeSource<+TR;>;
53 56 13 ms Lio/reactivex/MaybeSource<+TR;>;
46 53 14 ex Ljava/lang/Throwable;
58 64 9 e J
60 64 11 w TR;
Exception table:
from to target type
43 44 45 Class java.lang.Throwable
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/FlowableSubscriber<TT;>;Lorg/reactivestreams/Subscription;
SourceFile: "FlowableConcatMapMaybe.java"
NestHost: io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe
InnerClasses:
final ConcatMapMaybeSubscriber = io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber of io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe
final ConcatMapMaybeObserver = io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver of io.reactivex.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber