final class io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber<T, U> 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.flowable.FlowableFlatMap$MergeSubscriber
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 org.reactivestreams.Subscriber<? super U> downstream;
descriptor: Lorg/reactivestreams/Subscriber;
flags: (0x0010) ACC_FINAL
Signature: Lorg/reactivestreams/Subscriber<-TU;>;
final io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+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 errs;
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.flowable.FlowableFlatMap$InnerSubscriber<?, ?>[]> subscribers;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;>;
static final io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<?, ?>[] EMPTY;
descriptor: [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;
static final io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<?, ?>[] CANCELLED;
descriptor: [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;
final java.util.concurrent.atomic.AtomicLong requested;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0010) ACC_FINAL
org.reactivestreams.Subscription upstream;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
long uniqueId;
descriptor: J
flags: (0x0000)
long lastId;
descriptor: J
flags: (0x0000)
int lastIndex;
descriptor: I
flags: (0x0000)
int scalarEmitted;
descriptor: I
flags: (0x0000)
final int scalarLimit;
descriptor: I
flags: (0x0010) ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: iconst_0
anewarray io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber
putstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
1: iconst_0
anewarray io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber
putstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.reactivestreams.Subscriber<? super U>, io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>>, boolean, int, );
descriptor: (Lorg/reactivestreams/Subscriber;Lio/reactivex/functions/Function;ZII)V
flags: (0x0000)
Code:
stack=4, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
new io.reactivex.internal.util.AtomicThrowable
dup
invokespecial io.reactivex.internal.util.AtomicThrowable.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
2: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
3: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
4: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
5: aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.mapper:Lio/reactivex/functions/Function;
6: aload 0
iload 3
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.delayErrors:Z
7: aload 0
iload 4
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
8: aload 0
iload 5
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.bufferSize:I
9: aload 0
iconst_1
iload 4
iconst_1
ishr
invokestatic java.lang.Math.max:(II)I
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarLimit:I
10: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
11: return
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 12 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 12 1 actual Lorg/reactivestreams/Subscriber<-TU;>;
0 12 2 mapper Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TU;>;>;
0 12 3 delayErrors Z
0 12 4 maxConcurrency I
0 12 5 bufferSize I
Signature: (Lorg/reactivestreams/Subscriber<-TU;>;Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TU;>;>;ZII)V
MethodParameters:
Name Flags
actual
mapper
delayErrors
maxConcurrency
bufferSize
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.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 8
1: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 0
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
3: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifne 8
4: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
ldc 2147483647
if_icmpne 7
5: aload 1
ldc 9223372036854775807
invokeinterface org.reactivestreams.Subscription.request:(J)V
6: goto 8
7: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 9 1 s Lorg/reactivestreams/Subscription;
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.mapper:Lio/reactivex/functions/Function;
aload 1
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
ldc "The mapper returned a null Publisher"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
astore 2
start local 2 3: goto 9
end local 2 StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 3
start local 3 5: aload 3
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
6: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
7: aload 0
aload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onError:(Ljava/lang/Throwable;)V
8: return
end local 3 start local 2 9: StackMap locals: org.reactivestreams.Publisher
StackMap stack:
aload 2
instanceof java.util.concurrent.Callable
ifeq 25
10: aload 2
checkcast java.util.concurrent.Callable
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
astore 3
start local 3 11: goto 17
end local 3 StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 4
start local 4 13: aload 4
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
14: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
aload 4
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
pop
15: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain:()V
16: return
end local 4 start local 3 17: StackMap locals: java.lang.Object
StackMap stack:
aload 3
ifnull 20
18: aload 0
aload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.tryEmitScalar:(Ljava/lang/Object;)V
19: goto 28
20: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
ldc 2147483647
if_icmpeq 28
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifne 28
21: aload 0
dup
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
iconst_1
iadd
dup_x1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarLimit:I
if_icmpne 28
22: aload 0
iconst_0
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
23: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarLimit:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
end local 3 24: goto 28
25: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber
dup
aload 0
aload 0
dup
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.uniqueId:J
dup2_x1
lconst_1
ladd
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.uniqueId:J
invokespecial io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.<init>:(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;J)V
astore 3
start local 3 26: aload 0
aload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.addInner:(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Z
ifeq 28
27: aload 2
aload 3
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
end local 3 28: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 29 1 t TT;
3 4 2 p Lorg/reactivestreams/Publisher<+TU;>;
9 29 2 p Lorg/reactivestreams/Publisher<+TU;>;
5 9 3 e Ljava/lang/Throwable;
11 12 3 u TU;
17 24 3 u TU;
13 17 4 ex Ljava/lang/Throwable;
26 28 3 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
Exception table:
from to target type
2 3 4 Class java.lang.Throwable
10 11 12 Class java.lang.Throwable
Signature: (TT;)V
MethodParameters:
Name Flags
t
boolean addInner(io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<T, U>);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Z
flags: (0x0000)
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
astore 2
start local 2 1: aload 2
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if_acmpne 4
2: aload 1
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.dispose:()V
3: iconst_0
ireturn
4: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
StackMap stack:
aload 2
arraylength
istore 3
start local 3 5: iload 3
iconst_1
iadd
anewarray io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber
astore 4
start local 4 6: aload 2
iconst_0
aload 4
iconst_0
iload 3
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
7: aload 4
iload 3
aload 1
aastore
8: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
aload 2
aload 4
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
9: iconst_1
ireturn
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/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 10 1 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
1 10 2 a [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
5 10 3 n I
6 10 4 b [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
Signature: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;)Z
MethodParameters:
Name Flags
inner
void removeInner(io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<T, U>);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
flags: (0x0000)
Code:
stack=6, locals=6, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
astore 2
start local 2 1: aload 2
arraylength
istore 3
start local 3 2: iload 3
ifne 4
3: return
4: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[] int
StackMap stack:
iconst_m1
istore 4
start local 4 5: iconst_0
istore 5
start local 5 6: goto 11
7: StackMap locals: int int
StackMap stack:
aload 2
iload 5
aaload
aload 1
if_acmpne 10
8: iload 5
istore 4
9: goto 12
10: StackMap locals:
StackMap stack:
iinc 5 1
StackMap locals:
StackMap stack:
11: iload 5
iload 3
if_icmplt 7
end local 5 12: StackMap locals:
StackMap stack:
iload 4
ifge 14
13: return
14: StackMap locals:
StackMap stack:
iload 3
iconst_1
if_icmpne 17
15: getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
astore 5
start local 5 16: goto 20
end local 5 17: StackMap locals:
StackMap stack:
iload 3
iconst_1
isub
anewarray io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber
astore 5
start local 5 18: aload 2
iconst_0
aload 5
iconst_0
iload 4
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
19: aload 2
iload 4
iconst_1
iadd
aload 5
iload 4
iload 3
iload 4
isub
iconst_1
isub
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
20: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
aload 2
aload 5
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
21: return
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 22 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 22 1 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
1 22 2 a [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
2 22 3 n I
5 22 4 j I
6 12 5 i I
16 17 5 b [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
18 22 5 b [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
Signature: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;)V
MethodParameters:
Name Flags
inner
io.reactivex.internal.fuseable.SimpleQueue<U> getMainQueue();
descriptor: ()Lio/reactivex/internal/fuseable/SimpleQueue;
flags: (0x0000)
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 1
start local 1 1: aload 1
ifnonnull 7
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
ldc 2147483647
if_icmpne 5
3: new io.reactivex.internal.queue.SpscLinkedArrayQueue
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.bufferSize:I
invokespecial io.reactivex.internal.queue.SpscLinkedArrayQueue.<init>:(I)V
astore 1
4: goto 6
5: StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue
StackMap stack:
new io.reactivex.internal.queue.SpscArrayQueue
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
astore 1
6: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
7: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
1 8 1 q Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;
Signature: ()Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
void tryEmitScalar();
descriptor: (Ljava/lang/Object;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.get:()I
ifne 19
aload 0
iconst_0
iconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.compareAndSet:(II)Z
ifeq 19
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lstore 2
start local 2 2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 4
start local 4 3: lload 2
lconst_0
lcmp
ifeq 12
aload 4
ifnull 4
aload 4
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
ifeq 12
4: StackMap locals: long io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
5: lload 2
ldc 9223372036854775807
lcmp
ifeq 7
6: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
pop2
7: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.maxConcurrency:I
ldc 2147483647
if_icmpeq 17
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifne 17
8: aload 0
dup
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
iconst_1
iadd
dup_x1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarLimit:I
if_icmpne 17
9: aload 0
iconst_0
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarEmitted:I
10: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.scalarLimit:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
11: goto 17
12: StackMap locals:
StackMap stack:
aload 4
ifnonnull 14
13: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getMainQueue:()Lio/reactivex/internal/fuseable/SimpleQueue;
astore 4
14: StackMap locals:
StackMap stack:
aload 4
aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
ifne 17
15: aload 0
new java.lang.IllegalStateException
dup
ldc "Scalar queue full?!"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onError:(Ljava/lang/Throwable;)V
16: return
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.decrementAndGet:()I
ifne 25
18: return
end local 4 end local 2 19: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getMainQueue:()Lio/reactivex/internal/fuseable/SimpleQueue;
astore 2
start local 2 20: aload 2
aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
ifne 23
21: aload 0
new java.lang.IllegalStateException
dup
ldc "Scalar queue full?!"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onError:(Ljava/lang/Throwable;)V
22: return
23: StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getAndIncrement:()I
ifeq 25
24: return
end local 2 25: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop:()V
26: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 27 1 value TU;
2 19 2 r J
3 19 4 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
20 25 2 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
Signature: (TU;)V
MethodParameters:
Name Flags
value
io.reactivex.internal.fuseable.SimpleQueue<U> getInnerQueue(io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<T, U>);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Lio/reactivex/internal/fuseable/SimpleQueue;
flags: (0x0000)
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 2
start local 2 1: aload 2
ifnonnull 4
2: new io.reactivex.internal.queue.SpscArrayQueue
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.bufferSize:I
invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
astore 2
3: aload 1
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
4: StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 5 1 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
1 5 2 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
Signature: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;)Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
MethodParameters:
Name Flags
inner
void tryEmit(U, io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<T, U>);
descriptor: (Ljava/lang/Object;Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
flags: (0x0000)
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.get:()I
ifne 16
aload 0
iconst_0
iconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.compareAndSet:(II)Z
ifeq 16
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lstore 3
start local 3 2: aload 2
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 5
start local 5 3: lload 3
lconst_0
lcmp
ifeq 9
aload 5
ifnull 4
aload 5
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
ifeq 9
4: StackMap locals: long io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
5: lload 3
ldc 9223372036854775807
lcmp
ifeq 7
6: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
pop2
7: StackMap locals:
StackMap stack:
aload 2
lconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.requestMore:(J)V
8: goto 14
9: StackMap locals:
StackMap stack:
aload 5
ifnonnull 11
10: aload 0
aload 2
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getInnerQueue:(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Lio/reactivex/internal/fuseable/SimpleQueue;
astore 5
11: StackMap locals:
StackMap stack:
aload 5
aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
ifne 14
12: aload 0
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Inner queue full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onError:(Ljava/lang/Throwable;)V
13: return
14: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.decrementAndGet:()I
ifne 25
15: return
end local 5 end local 3 16: StackMap locals:
StackMap stack:
aload 2
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 3
start local 3 17: aload 3
ifnonnull 20
18: new io.reactivex.internal.queue.SpscArrayQueue
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.bufferSize:I
invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
astore 3
19: aload 2
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
20: StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 3
aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
ifne 23
21: aload 0
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Inner queue full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onError:(Ljava/lang/Throwable;)V
22: return
23: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getAndIncrement:()I
ifeq 25
24: return
end local 3 25: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop:()V
26: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 27 1 value TU;
0 27 2 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
2 16 3 r J
3 16 5 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
17 25 3 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
Signature: (TU;Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<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 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
ifeq 3
1: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
aload 1
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
ifeq 7
4: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
5: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain:()V
6: goto 8
7: StackMap locals:
StackMap stack:
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<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 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
3: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain:()V
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
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: lload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(J)Z
ifeq 3
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
lload 1
invokestatic io.reactivex.internal.util.BackpressureHelper.add:(Ljava/util/concurrent/atomic/AtomicLong;J)J
pop2
2: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain:()V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 4 1 n J
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifne 8
1: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
3: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.disposeAll:()V
4: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getAndIncrement:()I
ifne 8
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 1
start local 1 6: aload 1
ifnull 8
7: aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.clear:()V
end local 1 8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
6 8 1 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.getAndIncrement:()I
ifne 2
1: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
void drainLoop();
descriptor: ()V
flags: (0x0000)
Code:
stack=4, locals=24, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
astore 1
start local 1 1: iconst_1
istore 2
start local 2 2: StackMap locals: org.reactivestreams.Subscriber int
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 4
3: return
4: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 3
start local 3 5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lstore 4
start local 4 6: lload 4
ldc 9223372036854775807
lcmp
ifne 7
iconst_1
goto 8
StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue long
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: istore 6
start local 6 9: lconst_0
lstore 7
start local 7 10: aload 3
ifnull 30
11: StackMap locals: int long
StackMap stack:
lconst_0
lstore 9
start local 9 12: aconst_null
astore 11
start local 11 13: goto 23
14: StackMap locals: long java.lang.Object
StackMap stack:
aload 3
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.poll:()Ljava/lang/Object;
astore 11
15: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 17
16: return
17: StackMap locals:
StackMap stack:
aload 11
ifnonnull 19
18: goto 24
19: StackMap locals:
StackMap stack:
aload 1
aload 11
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
20: lload 7
lconst_1
ladd
lstore 7
21: lload 9
lconst_1
ladd
lstore 9
22: lload 4
lconst_1
lsub
lstore 4
23: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifne 14
24: StackMap locals:
StackMap stack:
lload 9
lconst_0
lcmp
ifeq 29
25: iload 6
ifeq 28
26: ldc 9223372036854775807
lstore 4
27: goto 29
28: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
lload 9
lneg
invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
lstore 4
29: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifeq 30
aload 11
ifnonnull 11
end local 11 end local 9 30: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.done:Z
istore 9
start local 9 31: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 3
32: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
astore 10
start local 10 33: aload 10
arraylength
istore 11
start local 11 34: iload 9
ifeq 43
aload 3
ifnull 35
aload 3
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.isEmpty:()Z
ifeq 43
StackMap locals: int io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[] int
StackMap stack:
35: iload 11
ifne 43
36: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 12
start local 12 37: aload 12
getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
if_acmpeq 42
38: aload 12
ifnonnull 41
39: aload 1
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
40: goto 42
41: StackMap locals: java.lang.Throwable
StackMap stack:
aload 1
aload 12
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
42: StackMap locals:
StackMap stack:
return
end local 12 43: StackMap locals:
StackMap stack:
iconst_0
istore 12
start local 12 44: iload 11
ifeq 124
45: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastId:J
lstore 13
start local 13 46: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastIndex:I
istore 15
start local 15 47: iload 11
iload 15
if_icmple 48
aload 10
iload 15
aaload
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.id:J
lload 13
lcmp
ifeq 63
48: StackMap locals: int long int
StackMap stack:
iload 11
iload 15
if_icmpgt 50
49: iconst_0
istore 15
50: StackMap locals:
StackMap stack:
iload 15
istore 16
start local 16 51: iconst_0
istore 17
start local 17 52: goto 59
53: StackMap locals: int int
StackMap stack:
aload 10
iload 16
aaload
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.id:J
lload 13
lcmp
ifne 55
54: goto 60
55: StackMap locals:
StackMap stack:
iinc 16 1
56: iload 16
iload 11
if_icmpne 58
57: iconst_0
istore 16
58: StackMap locals:
StackMap stack:
iinc 17 1
StackMap locals:
StackMap stack:
59: iload 17
iload 11
if_icmplt 53
end local 17 60: StackMap locals:
StackMap stack:
iload 16
istore 15
61: aload 0
iload 16
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastIndex:I
62: aload 0
aload 10
iload 16
aaload
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.id:J
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastId:J
end local 16 63: StackMap locals:
StackMap stack:
iload 15
istore 16
start local 16 64: iconst_0
istore 17
start local 17 65: goto 121
66: StackMap locals: int int
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 68
67: return
68: StackMap locals:
StackMap stack:
aload 10
iload 16
aaload
astore 18
start local 18 69: aconst_null
astore 19
start local 19 70: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber java.lang.Object
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 72
71: return
72: StackMap locals:
StackMap stack:
aload 18
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 20
start local 20 73: aload 20
ifnonnull 75
74: goto 106
75: StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
lconst_0
lstore 21
start local 21 76: goto 98
77: StackMap locals: long
StackMap stack:
aload 20
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
astore 19
78: goto 91
StackMap locals:
StackMap stack: java.lang.Throwable
79: astore 23
start local 23 80: aload 23
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
81: aload 18
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.dispose:()V
82: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
aload 23
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
pop
83: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.delayErrors:Z
ifne 85
84: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
85: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 87
86: return
87: StackMap locals:
StackMap stack:
aload 0
aload 18
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.removeInner:(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
88: iconst_1
istore 12
89: iinc 17 1
90: goto 120
end local 23 91: StackMap locals:
StackMap stack:
aload 19
ifnonnull 93
92: goto 99
93: StackMap locals:
StackMap stack:
aload 1
aload 19
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
94: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 96
95: return
96: StackMap locals:
StackMap stack:
lload 4
lconst_1
lsub
lstore 4
97: lload 21
lconst_1
ladd
lstore 21
98: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifne 77
99: StackMap locals:
StackMap stack:
lload 21
lconst_0
lcmp
ifeq 105
100: iload 6
ifne 103
101: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.requested:Ljava/util/concurrent/atomic/AtomicLong;
lload 21
lneg
invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
lstore 4
102: goto 104
103: StackMap locals:
StackMap stack:
ldc 9223372036854775807
lstore 4
104: StackMap locals:
StackMap stack:
aload 18
lload 21
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.requestMore:(J)V
105: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifeq 106
aload 19
ifnonnull 70
end local 21 end local 20 106: StackMap locals:
StackMap stack:
aload 18
107: getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.done:Z
istore 20
start local 20 108: aload 18
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 21
start local 21 109: iload 20
ifeq 115
aload 21
ifnull 110
aload 21
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
ifeq 115
110: StackMap locals: int io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
aload 0
aload 18
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.removeInner:(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
111: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.checkTerminate:()Z
ifeq 113
112: return
113: StackMap locals:
StackMap stack:
lload 7
lconst_1
ladd
lstore 7
114: iconst_1
istore 12
115: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifne 117
116: goto 122
117: StackMap locals:
StackMap stack:
iinc 16 1
118: iload 16
iload 11
if_icmpne 120
119: iconst_0
istore 16
end local 21 end local 20 end local 19 end local 18 120: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber org.reactivestreams.Subscriber int io.reactivex.internal.fuseable.SimplePlainQueue long int long int io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[] int int long int int int
StackMap stack:
iinc 17 1
StackMap locals:
StackMap stack:
121: iload 17
iload 11
if_icmplt 66
end local 17 122: StackMap locals:
StackMap stack:
aload 0
iload 16
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastIndex:I
123: aload 0
aload 10
iload 16
aaload
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.id:J
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.lastId:J
end local 16 end local 15 end local 13 124: StackMap locals:
StackMap stack:
lload 7
lconst_0
lcmp
ifeq 126
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifne 126
125: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
lload 7
invokeinterface org.reactivestreams.Subscription.request:(J)V
126: StackMap locals:
StackMap stack:
iload 12
ifeq 128
127: goto 2
128: StackMap locals:
StackMap stack:
aload 0
iload 2
ineg
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.addAndGet:(I)I
istore 2
129: iload 2
ifne 2
end local 12 end local 11 end local 10 end local 9 end local 7 end local 6 end local 4 end local 3 130: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 131 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
1 131 1 child Lorg/reactivestreams/Subscriber<-TU;>;
2 131 2 missed I
5 130 3 svq Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;
6 130 4 r J
9 130 6 unbounded Z
10 130 7 replenishMain J
12 30 9 scalarEmission J
13 30 11 o TU;
31 130 9 d Z
33 130 10 inner [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
34 130 11 n I
37 43 12 ex Ljava/lang/Throwable;
44 130 12 innerCompleted Z
46 124 13 startId J
47 124 15 index I
51 63 16 j I
52 60 17 i I
64 124 16 j I
65 122 17 i I
69 120 18 is Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
70 120 19 o TU;
73 106 20 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
76 106 21 produced J
80 91 23 ex Ljava/lang/Throwable;
108 120 20 innerDone Z
109 120 21 innerQueue Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
Exception table:
from to target type
77 78 79 Class java.lang.Throwable
boolean checkTerminate();
descriptor: ()Z
flags: (0x0000)
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.cancelled:Z
ifeq 3
1: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.clearScalarQueue:()V
2: iconst_1
ireturn
3: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.delayErrors:Z
ifne 9
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
ifnull 9
4: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.clearScalarQueue:()V
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 1
start local 1 6: aload 1
getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
if_acmpeq 8
7: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
8: StackMap locals: java.lang.Throwable
StackMap stack:
iconst_1
ireturn
end local 1 9: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
6 9 1 ex Ljava/lang/Throwable;
void clearScalarQueue();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.clear:()V
3: StackMap locals: io.reactivex.internal.fuseable.SimpleQueue
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
1 4 1 q Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;
void disposeAll();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=6, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
astore 1
start local 1 1: aload 1
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if_acmpeq 12
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
astore 1
3: aload 1
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if_acmpeq 12
4: aload 1
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 8
StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[] top int int io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
StackMap stack:
5: aload 5
iload 3
aaload
astore 2
start local 2 6: aload 2
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.dispose:()V
end local 2 7: iinc 3 1
StackMap locals:
StackMap stack:
8: iload 3
iload 4
if_icmplt 5
9: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.terminate:()Ljava/lang/Throwable;
astore 2
start local 2 10: aload 2
ifnull 12
aload 2
getstatic io.reactivex.internal.util.ExceptionHelper.TERMINATED:Ljava/lang/Throwable;
if_acmpeq 12
11: aload 2
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
end local 2 12: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
1 13 1 a [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
6 7 2 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;
10 12 2 ex Ljava/lang/Throwable;
void innerError(io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber<T, U>, java.lang.Throwable);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.errs:Lio/reactivex/internal/util/AtomicThrowable;
aload 2
invokevirtual io.reactivex.internal.util.AtomicThrowable.addThrowable:(Ljava/lang/Throwable;)Z
ifeq 11
1: aload 1
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.done:Z
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.delayErrors:Z
ifne 9
3: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
4: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 8
StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber java.lang.Throwable top int int io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber[]
StackMap stack:
5: aload 6
iload 4
aaload
astore 3
start local 3 6: aload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.dispose:()V
end local 3 7: iinc 4 1
StackMap locals:
StackMap stack:
8: iload 4
iload 5
if_icmplt 5
9: StackMap locals: io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber java.lang.Throwable
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain:()V
10: goto 12
11: StackMap locals:
StackMap stack:
aload 2
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;
0 13 1 inner Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;
0 13 2 t Ljava/lang/Throwable;
6 7 3 a Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;
Signature: (Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;Ljava/lang/Throwable;)V
MethodParameters:
Name Flags
inner
t
}
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/FlowableSubscriber<TT;>;Lorg/reactivestreams/Subscription;
SourceFile: "FlowableFlatMap.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableFlatMap
InnerClasses:
final InnerSubscriber = io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber of io.reactivex.internal.operators.flowable.FlowableFlatMap
final MergeSubscriber = io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber of io.reactivex.internal.operators.flowable.FlowableFlatMap