final class io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription<T> extends io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscriptionBase<T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription
super_class: io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscriptionBase
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 6312374661811000451
void <init>(org.reactivestreams.Subscriber<? super T>, int, );
descriptor: (Lorg/reactivestreams/Subscriber;II)V
flags: (0x0000)
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
invokespecial io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscriptionBase.<init>:(Lorg/reactivestreams/Subscriber;II)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinSubscription<TT;>;
0 2 1 actual Lorg/reactivestreams/Subscriber<-TT;>;
0 2 2 n I
0 2 3 prefetch I
Signature: (Lorg/reactivestreams/Subscriber<-TT;>;II)V
MethodParameters:
Name Flags
actual
n
prefetch
public void onNext(io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber<T>, );
descriptor: (Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.get:()I
ifne 18
aload 0
iconst_0
iconst_1
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.compareAndSet:(II)Z
ifeq 18
1: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lconst_0
lcmp
ifeq 7
2: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.downstream:Lorg/reactivestreams/Subscriber;
aload 2
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
3: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
ldc 9223372036854775807
lcmp
ifeq 5
4: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
pop2
5: StackMap locals:
StackMap stack:
aload 1
lconst_1
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.request:(J)V
6: goto 16
7: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.getQueue:()Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 3
start local 3 8: aload 3
aload 2
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
ifne 16
9: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cancelAll:()V
10: new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Queue full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
astore 4
start local 4 11: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.errors:Lio/reactivex/internal/util/AtomicThrowable;
aconst_null
aload 4
invokevirtual io.reactivex.internal.util.AtomicThrowable.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 14
12: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.downstream:Lorg/reactivestreams/Subscriber;
aload 4
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
13: goto 15
14: StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue java.lang.Throwable
StackMap stack:
aload 4
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
15: StackMap locals:
StackMap stack:
return
end local 4 end local 3 16: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.decrementAndGet:()I
ifne 25
17: return
18: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.getQueue:()Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 3
start local 3 19: aload 3
aload 2
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
ifne 23
20: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cancelAll:()V
21: aload 0
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Queue full?!"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.onError:(Ljava/lang/Throwable;)V
22: return
23: StackMap locals: io.reactivex.internal.fuseable.SimplePlainQueue
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.getAndIncrement:()I
ifeq 25
24: return
end local 3 25: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.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/parallel/ParallelJoin$JoinSubscription<TT;>;
0 27 1 inner Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber<TT;>;
0 27 2 value TT;
8 16 3 q Lio/reactivex/internal/fuseable/SimplePlainQueue<TT;>;
11 16 4 mbe Ljava/lang/Throwable;
19 25 3 q Lio/reactivex/internal/fuseable/SimplePlainQueue<TT;>;
Signature: (Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber<TT;>;TT;)V
MethodParameters:
Name Flags
inner
value
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)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.parallel.ParallelJoin$JoinSubscription.errors:Lio/reactivex/internal/util/AtomicThrowable;
aconst_null
aload 1
invokevirtual io.reactivex.internal.util.AtomicThrowable.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 4
1: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cancelAll:()V
2: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.drain:()V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.errors:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
if_acmpeq 6
5: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)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/parallel/ParallelJoin$JoinSubscription<TT;>;
0 7 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.done:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
pop
1: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinSubscription<TT;>;
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.parallel.ParallelJoin$JoinSubscription.getAndIncrement:()I
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.drainLoop:()V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinSubscription<TT;>;
void drainLoop();
descriptor: ()V
flags: (0x0000)
Code:
stack=4, locals=16, args_size=1
start local 0 0: iconst_1
istore 1
start local 1 1: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.subscribers:[Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber;
astore 2
start local 2 2: aload 2
arraylength
istore 3
start local 3 3: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.downstream:Lorg/reactivestreams/Subscriber;
astore 4
start local 4 4: StackMap locals: io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription int io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber[] int org.reactivestreams.Subscriber
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.requested:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lstore 5
start local 5 5: lconst_0
lstore 7
start local 7 6: goto 38
7: StackMap locals: long long
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cancelled:Z
ifeq 10
8: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cleanup:()V
9: return
10: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.errors:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
checkcast java.lang.Throwable
astore 9
start local 9 11: aload 9
ifnull 15
12: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cleanup:()V
13: aload 4
aload 9
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
14: return
15: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.done:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
ifne 16
iconst_1
goto 17
StackMap locals:
StackMap stack:
16: iconst_0
StackMap locals:
StackMap stack: int
17: istore 10
start local 10 18: iconst_1
istore 11
start local 11 19: iconst_0
istore 12
start local 12 20: goto 32
21: StackMap locals: int int int
StackMap stack:
aload 2
iload 12
aaload
astore 13
start local 13 22: aload 13
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 14
start local 14 23: aload 14
ifnull 31
24: aload 14
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.poll:()Ljava/lang/Object;
astore 15
start local 15 25: aload 15
ifnull 31
26: iconst_0
istore 11
27: aload 4
aload 15
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
28: aload 13
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.requestOne:()V
29: lload 7
lconst_1
ladd
dup2
lstore 7
lload 5
lcmp
ifne 31
30: goto 39
end local 15 end local 14 end local 13 31: StackMap locals:
StackMap stack:
iinc 12 1
StackMap locals:
StackMap stack:
32: iload 12
aload 2
arraylength
if_icmplt 21
end local 12 33: iload 10
ifeq 36
iload 11
ifeq 36
34: aload 4
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
35: return
36: StackMap locals:
StackMap stack:
iload 11
ifeq 38
37: goto 39
end local 11 end local 10 end local 9 38: StackMap locals:
StackMap stack:
lload 7
lload 5
lcmp
ifne 7
39: StackMap locals:
StackMap stack:
lload 7
lload 5
lcmp
ifne 64
40: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cancelled:Z
ifeq 43
41: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cleanup:()V
42: return
43: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.errors:Lio/reactivex/internal/util/AtomicThrowable;
invokevirtual io.reactivex.internal.util.AtomicThrowable.get:()Ljava/lang/Object;
checkcast java.lang.Throwable
astore 9
start local 9 44: aload 9
ifnull 48
45: aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.cleanup:()V
46: aload 4
aload 9
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
47: return
48: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.done:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
ifne 49
iconst_1
goto 50
StackMap locals:
StackMap stack:
49: iconst_0
StackMap locals:
StackMap stack: int
50: istore 10
start local 10 51: iconst_1
istore 11
start local 11 52: iconst_0
istore 12
start local 12 53: goto 60
54: StackMap locals: int int int
StackMap stack:
aload 2
iload 12
aaload
astore 13
start local 13 55: aload 13
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 14
start local 14 56: aload 14
ifnull 59
aload 14
invokeinterface io.reactivex.internal.fuseable.SimpleQueue.isEmpty:()Z
ifne 59
57: iconst_0
istore 11
58: goto 61
end local 14 end local 13 59: StackMap locals:
StackMap stack:
iinc 12 1
StackMap locals:
StackMap stack:
60: iload 12
iload 3
if_icmplt 54
end local 12 61: StackMap locals:
StackMap stack:
iload 10
ifeq 64
iload 11
ifeq 64
62: aload 4
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
63: return
end local 11 end local 10 end local 9 64: StackMap locals:
StackMap stack:
lload 7
lconst_0
lcmp
ifeq 66
lload 5
ldc 9223372036854775807
lcmp
ifeq 66
65: aload 0
getfield io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.requested:Ljava/util/concurrent/atomic/AtomicLong;
lload 7
lneg
invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
pop2
66: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.get:()I
istore 9
start local 9 67: iload 9
iload 1
if_icmpne 71
68: aload 0
iload 1
ineg
invokevirtual io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription.addAndGet:(I)I
istore 1
69: iload 1
ifne 4
70: goto 73
71: StackMap locals: int
StackMap stack:
iload 9
istore 1
end local 9 end local 7 end local 5 72: goto 4
73: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 74 0 this Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinSubscription<TT;>;
1 74 1 missed I
2 74 2 s [Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber;
3 74 3 n I
4 74 4 a Lorg/reactivestreams/Subscriber<-TT;>;
5 72 5 r J
6 72 7 e J
11 38 9 ex Ljava/lang/Throwable;
18 38 10 d Z
19 38 11 empty Z
20 33 12 i I
22 31 13 inner Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber<TT;>;
23 31 14 q Lio/reactivex/internal/fuseable/SimplePlainQueue<TT;>;
25 31 15 v TT;
44 64 9 ex Ljava/lang/Throwable;
51 64 10 d Z
52 64 11 empty Z
53 61 12 i I
55 59 13 inner Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinInnerSubscriber<TT;>;
56 59 14 q Lio/reactivex/internal/fuseable/SimpleQueue<TT;>;
67 72 9 w I
}
Signature: <T:Ljava/lang/Object;>Lio/reactivex/internal/operators/parallel/ParallelJoin$JoinSubscriptionBase<TT;>;
SourceFile: "ParallelJoin.java"
NestHost: io.reactivex.internal.operators.parallel.ParallelJoin
InnerClasses:
final JoinInnerSubscriber = io.reactivex.internal.operators.parallel.ParallelJoin$JoinInnerSubscriber of io.reactivex.internal.operators.parallel.ParallelJoin
final JoinSubscription = io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscription of io.reactivex.internal.operators.parallel.ParallelJoin
abstract JoinSubscriptionBase = io.reactivex.internal.operators.parallel.ParallelJoin$JoinSubscriptionBase of io.reactivex.internal.operators.parallel.ParallelJoin