final class io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection<T> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.FlowableSubscriber<T>, io.reactivex.disposables.Disposable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection
super_class: java.util.concurrent.atomic.AtomicInteger
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -1672047311619175801
final java.util.concurrent.atomic.AtomicReference<io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection<T>> current;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;>;
final java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> upstream;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lorg/reactivestreams/Subscription;>;
final java.util.concurrent.atomic.AtomicBoolean connect;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0010) ACC_FINAL
final java.util.concurrent.atomic.AtomicReference<io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription<T>[]> subscribers;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;>;
final int bufferSize;
descriptor: I
flags: (0x0010) ACC_FINAL
volatile io.reactivex.internal.fuseable.SimpleQueue<T> queue;
descriptor: Lio/reactivex/internal/fuseable/SimpleQueue;
flags: (0x0040) ACC_VOLATILE
Signature: Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
int sourceMode;
descriptor: I
flags: (0x0000)
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
java.lang.Throwable error;
descriptor: Ljava/lang/Throwable;
flags: (0x0000)
int consumed;
descriptor: I
flags: (0x0000)
static final io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] EMPTY;
descriptor: [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] TERMINATED;
descriptor: [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
flags: (0x0018) ACC_STATIC, 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.FlowablePublishAlt$InnerSubscription
putstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
1: iconst_0
anewarray io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription
putstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(java.util.concurrent.atomic.AtomicReference<io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection<T>>, );
descriptor: (Ljava/util/concurrent/atomic/AtomicReference;I)V
flags: (0x0000)
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.current:Ljava/util/concurrent/atomic/AtomicReference;
2: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.upstream:Ljava/util/concurrent/atomic/AtomicReference;
3: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.connect:Ljava/util/concurrent/atomic/AtomicBoolean;
4: aload 0
iload 2
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
5: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 7 1 current Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;>;
0 7 2 bufferSize I
Signature: (Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;>;I)V
MethodParameters:
Name Flags
current
bufferSize
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.current:Ljava/util/concurrent/atomic/AtomicReference;
aload 0
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.upstream:Ljava/util/concurrent/atomic/AtomicReference;
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.cancel:(Ljava/util/concurrent/atomic/AtomicReference;)Z
pop
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.upstream:Ljava/util/concurrent/atomic/AtomicReference;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.setOnce:(Ljava/util/concurrent/atomic/AtomicReference;Lorg/reactivestreams/Subscription;)Z
ifeq 17
1: aload 1
instanceof io.reactivex.internal.fuseable.QueueSubscription
ifeq 15
2: aload 1
checkcast io.reactivex.internal.fuseable.QueueSubscription
astore 2
start local 2 3: aload 2
bipush 7
invokeinterface io.reactivex.internal.fuseable.QueueSubscription.requestFusion:(I)I
istore 3
start local 3 4: iload 3
iconst_1
if_icmpne 10
5: aload 0
iload 3
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.sourceMode:I
6: aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
7: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.done:Z
8: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.drain:()V
9: return
10: StackMap locals: io.reactivex.internal.fuseable.QueueSubscription int
StackMap stack:
iload 3
iconst_2
if_icmpne 15
11: aload 0
iload 3
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.sourceMode:I
12: aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
13: aload 1
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
14: return
end local 3 end local 2 15: StackMap locals:
StackMap stack:
aload 0
new io.reactivex.internal.queue.SpscArrayQueue
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
invokespecial io.reactivex.internal.queue.SpscArrayQueue.<init>:(I)V
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
16: aload 1
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
17: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 18 1 s Lorg/reactivestreams/Subscription;
3 15 2 qs Lio/reactivex/internal/fuseable/QueueSubscription<TT;>;
4 15 3 m I
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.flowable.FlowablePublishAlt$PublishConnection.sourceMode:I
ifne 3
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
aload 1
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.offer:(Ljava/lang/Object;)Z
ifne 3
1: aload 0
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Prefetch queue is full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.onError:(Ljava/lang/Throwable;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.drain:()V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 5 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.flowable.FlowablePublishAlt$PublishConnection.done:Z
ifeq 3
1: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
2: goto 6
3: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.error:Ljava/lang/Throwable;
4: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.done:Z
5: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.drain:()V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 7 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.flowable.FlowablePublishAlt$PublishConnection.done:Z
1: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=17, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.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.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 2
start local 2 4: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.consumed:I
istore 3
start local 3 5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.bufferSize:I
iconst_2
ishr
isub
istore 4
start local 4 6: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.sourceMode:I
iconst_1
if_icmpeq 7
iconst_1
goto 8
StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: istore 5
start local 5 9: StackMap locals: int
StackMap stack:
aload 2
ifnull 57
10: ldc 9223372036854775807
lstore 6
start local 6 11: iconst_0
istore 8
start local 8 12: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
astore 9
start local 9 13: aload 9
dup
astore 13
arraylength
istore 12
iconst_0
istore 11
goto 20
StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int int long int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] top int int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
14: aload 13
iload 11
aaload
astore 10
start local 10 15: aload 10
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.get:()J
lstore 14
start local 14 16: lload 14
ldc -9223372036854775808
lcmp
ifeq 19
17: iconst_1
istore 8
18: lload 14
aload 10
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.emitted:J
lsub
lload 6
invokestatic java.lang.Math.min:(JJ)J
lstore 6
end local 14 end local 10 19: StackMap locals:
StackMap stack:
iinc 11 1
StackMap locals:
StackMap stack:
20: iload 11
iload 12
if_icmplt 14
21: iload 8
ifne 54
22: lconst_0
lstore 6
23: goto 54
24: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int int long int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.done:Z
istore 10
start local 10 25: aload 2
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.poll:()Ljava/lang/Object;
astore 11
start local 11 26: goto 34
end local 11 StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int int long int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] int
StackMap stack: java.lang.Throwable
27: astore 12
start local 12 28: aload 12
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
29: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.upstream:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.reactivestreams.Subscription
invokeinterface org.reactivestreams.Subscription.cancel:()V
30: aload 2
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.clear:()V
31: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.done:Z
32: aload 0
aload 12
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.signalError:(Ljava/lang/Throwable;)V
33: return
end local 12 start local 11 34: StackMap locals: java.lang.Object
StackMap stack:
aload 11
ifnonnull 35
iconst_1
goto 36
StackMap locals:
StackMap stack:
35: iconst_0
StackMap locals:
StackMap stack: int
36: istore 12
start local 12 37: aload 0
iload 10
iload 12
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.checkTerminated:(ZZ)Z
ifeq 39
38: return
39: StackMap locals: int
StackMap stack:
iload 12
ifeq 41
40: goto 55
41: StackMap locals:
StackMap stack:
aload 9
dup
astore 16
arraylength
istore 15
iconst_0
istore 14
goto 47
StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int int long int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] int java.lang.Object int top int int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
42: aload 16
iload 14
aaload
astore 13
start local 13 43: aload 13
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.isCancelled:()Z
ifne 46
44: aload 13
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.downstream:Lorg/reactivestreams/Subscriber;
aload 11
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
45: aload 13
dup
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.emitted:J
lconst_1
ladd
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.emitted:J
end local 13 46: StackMap locals:
StackMap stack:
iinc 14 1
StackMap locals:
StackMap stack:
47: iload 14
iload 15
if_icmplt 42
48: iload 5
ifeq 51
iinc 3 1
iload 3
iload 4
if_icmpne 51
49: iconst_0
istore 3
50: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.upstream:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.reactivestreams.Subscription
iload 4
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
51: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int io.reactivex.internal.fuseable.SimpleQueue int int int long int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] int java.lang.Object int
StackMap stack:
lload 6
lconst_1
lsub
lstore 6
52: aload 9
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
if_acmpeq 54
53: goto 9
end local 12 end local 11 end local 10 54: StackMap locals:
StackMap stack:
lload 6
lconst_0
lcmp
ifne 24
55: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.done:Z
aload 2
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.checkTerminated:(ZZ)Z
ifeq 57
56: return
end local 9 end local 8 end local 6 57: StackMap locals:
StackMap stack:
aload 0
iload 3
putfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.consumed:I
58: aload 0
iload 1
ineg
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.addAndGet:(I)I
istore 1
59: iload 1
ifne 61
60: goto 64
61: StackMap locals:
StackMap stack:
aload 2
ifnonnull 9
62: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.queue:Lio/reactivex/internal/fuseable/SimpleQueue;
astore 2
63: goto 9
64: StackMap locals:
StackMap stack:
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 65 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
3 65 1 missed I
4 65 2 queue Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
5 65 3 consumed I
6 65 4 limit I
9 65 5 async Z
11 57 6 minDemand J
12 57 8 hasDemand Z
13 57 9 innerSubscriptions [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
15 19 10 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
16 19 14 request J
25 54 10 d Z
26 27 11 v TT;
34 54 11 v TT;
28 34 12 ex Ljava/lang/Throwable;
37 54 12 empty Z
43 46 13 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
Exception table:
from to target type
25 26 27 Class java.lang.Throwable
boolean checkTerminated(boolean, boolean);
descriptor: (ZZ)Z
flags: (0x0000)
Code:
stack=2, locals=8, args_size=3
start local 0 start local 1 start local 2 0: iload 1
ifeq 12
iload 2
ifeq 12
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.error:Ljava/lang/Throwable;
astore 3
start local 3 2: aload 3
ifnull 5
3: aload 0
aload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.signalError:(Ljava/lang/Throwable;)V
4: goto 11
5: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 10
StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int int java.lang.Throwable top int int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
6: aload 7
iload 5
aaload
astore 4
start local 4 7: aload 4
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.isCancelled:()Z
ifne 9
8: aload 4
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.downstream:Lorg/reactivestreams/Subscriber;
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
end local 4 9: StackMap locals:
StackMap stack:
iinc 5 1
StackMap locals:
StackMap stack:
10: iload 5
iload 6
if_icmplt 6
11: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection int int java.lang.Throwable
StackMap stack:
iconst_1
ireturn
end local 3 12: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 13 1 isDone Z
0 13 2 isEmpty Z
2 12 3 ex Ljava/lang/Throwable;
7 9 4 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
MethodParameters:
Name Flags
isDone
isEmpty
void signalError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 5
StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection java.lang.Throwable top int int io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
1: aload 5
iload 3
aaload
astore 2
start local 2 2: aload 2
invokevirtual io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.isCancelled:()Z
ifne 4
3: aload 2
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
end local 2 4: StackMap locals:
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
5: iload 3
iload 4
if_icmplt 1
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 7 1 ex Ljava/lang/Throwable;
2 4 2 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
MethodParameters:
Name Flags
ex
boolean add(io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription<T>);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;)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.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
astore 2
start local 2 1: aload 2
getstatic io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.TERMINATED:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
if_acmpne 3
2: iconst_0
ireturn
3: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
aload 2
arraylength
istore 3
start local 3 4: iload 3
iconst_1
iadd
anewarray io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription
astore 4
start local 4 5: aload 2
iconst_0
aload 4
iconst_0
iload 3
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
6: aload 4
iload 3
aload 1
aastore
7: aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.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
8: 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 9 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 9 1 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
1 9 2 c [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
4 9 3 len I
5 9 4 u [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
Signature: (Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;)Z
MethodParameters:
Name Flags
inner
void remove(io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription<T>);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;)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.FlowablePublishAlt$PublishConnection.subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[]
astore 2
start local 2 1: aload 2
arraylength
istore 3
start local 3 2: iload 3
ifne 4
3: goto 21
4: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription[] 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.FlowablePublishAlt$PublishConnection.EMPTY:[Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
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.FlowablePublishAlt$InnerSubscription
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.FlowablePublishAlt$InnerSubscription[]
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection.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
end local 5 end local 4 end local 3 end local 2 21: StackMap locals: io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$PublishConnection<TT;>;
0 22 1 inner Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;
1 21 2 c [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
2 21 3 len I
5 21 4 j I
6 12 5 i I
16 17 5 u [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
18 21 5 u [Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription;
Signature: (Lio/reactivex/internal/operators/flowable/FlowablePublishAlt$InnerSubscription<TT;>;)V
MethodParameters:
Name Flags
inner
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/FlowableSubscriber<TT;>;Lio/reactivex/disposables/Disposable;
SourceFile: "FlowablePublishAlt.java"
NestHost: io.reactivex.internal.operators.flowable.FlowablePublishAlt
InnerClasses:
final InnerSubscription = io.reactivex.internal.operators.flowable.FlowablePublishAlt$InnerSubscription of io.reactivex.internal.operators.flowable.FlowablePublishAlt
final PublishConnection = io.reactivex.internal.operators.flowable.FlowablePublishAlt$PublishConnection of io.reactivex.internal.operators.flowable.FlowablePublishAlt