public final class io.reactivex.internal.operators.completable.CompletableMergeIterable extends io.reactivex.Completable
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.completable.CompletableMergeIterable
super_class: io.reactivex.Completable
{
final java.lang.Iterable<? extends io.reactivex.CompletableSource> sources;
descriptor: Ljava/lang/Iterable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
public void <init>(java.lang.Iterable<? extends io.reactivex.CompletableSource>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 // io.reactivex.internal.operators.completable.CompletableMergeIterable this
start local 1 // java.lang.Iterable sources
0: .line 28
aload 0 /* this */
invokespecial io.reactivex.Completable.<init>:()V
1: .line 29
aload 0 /* this */
aload 1 /* sources */
putfield io.reactivex.internal.operators.completable.CompletableMergeIterable.sources:Ljava/lang/Iterable;
2: .line 30
return
end local 1 // java.lang.Iterable sources
end local 0 // io.reactivex.internal.operators.completable.CompletableMergeIterable this
LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/completable/CompletableMergeIterable;
0 3 1 sources Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;
Signature: (Ljava/lang/Iterable<+Lio/reactivex/CompletableSource;>;)V
MethodParameters:
Name Flags
sources
public void subscribeActual(io.reactivex.CompletableObserver);
descriptor: (Lio/reactivex/CompletableObserver;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=9, args_size=2
start local 0 // io.reactivex.internal.operators.completable.CompletableMergeIterable this
start local 1 // io.reactivex.CompletableObserver observer
0: .line 34
new io.reactivex.disposables.CompositeDisposable
dup
invokespecial io.reactivex.disposables.CompositeDisposable.<init>:()V
astore 2 /* set */
start local 2 // io.reactivex.disposables.CompositeDisposable set
1: .line 36
aload 1 /* observer */
aload 2 /* set */
invokeinterface io.reactivex.CompletableObserver.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
2: .line 41
aload 0 /* this */
getfield io.reactivex.internal.operators.completable.CompletableMergeIterable.sources:Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
ldc "The source iterator returned is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.Iterator
astore 3 /* iterator */
start local 3 // java.util.Iterator iterator
3: .line 42
goto 8
end local 3 // java.util.Iterator iterator
StackMap locals: io.reactivex.internal.operators.completable.CompletableMergeIterable io.reactivex.CompletableObserver io.reactivex.disposables.CompositeDisposable
StackMap stack: java.lang.Throwable
4: astore 4 /* e */
start local 4 // java.lang.Throwable e
5: .line 43
aload 4 /* e */
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
6: .line 44
aload 1 /* observer */
aload 4 /* e */
invokeinterface io.reactivex.CompletableObserver.onError:(Ljava/lang/Throwable;)V
7: .line 45
return
end local 4 // java.lang.Throwable e
start local 3 // java.util.Iterator iterator
8: .line 48
StackMap locals: java.util.Iterator
StackMap stack:
new java.util.concurrent.atomic.AtomicInteger
dup
iconst_1
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:(I)V
astore 4 /* wip */
start local 4 // java.util.concurrent.atomic.AtomicInteger wip
9: .line 50
new io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver
dup
aload 1 /* observer */
aload 2 /* set */
aload 4 /* wip */
invokespecial io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver.<init>:(Lio/reactivex/CompletableObserver;Lio/reactivex/disposables/CompositeDisposable;Ljava/util/concurrent/atomic/AtomicInteger;)V
astore 5 /* shared */
start local 5 // io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver shared
10: .line 52
StackMap locals: java.util.concurrent.atomic.AtomicInteger io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver
StackMap stack:
aload 2 /* set */
invokevirtual io.reactivex.disposables.CompositeDisposable.isDisposed:()Z
ifeq 12
11: .line 53
return
12: .line 58
StackMap locals:
StackMap stack:
aload 3 /* iterator */
invokeinterface java.util.Iterator.hasNext:()Z
istore 6 /* b */
start local 6 // boolean b
13: .line 59
goto 19
end local 6 // boolean b
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 7 /* e */
start local 7 // java.lang.Throwable e
15: .line 60
aload 7 /* e */
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
16: .line 61
aload 2 /* set */
invokevirtual io.reactivex.disposables.CompositeDisposable.dispose:()V
17: .line 62
aload 5 /* shared */
aload 7 /* e */
invokevirtual io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver.onError:(Ljava/lang/Throwable;)V
18: .line 63
return
end local 7 // java.lang.Throwable e
start local 6 // boolean b
19: .line 66
StackMap locals: int
StackMap stack:
iload 6 /* b */
ifne 21
20: .line 67
goto 35
21: .line 70
StackMap locals:
StackMap stack:
aload 2 /* set */
invokevirtual io.reactivex.disposables.CompositeDisposable.isDisposed:()Z
ifeq 23
22: .line 71
return
23: .line 77
StackMap locals:
StackMap stack:
aload 3 /* iterator */
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.reactivex.CompletableSource
ldc "The iterator returned a null CompletableSource"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.CompletableSource
astore 7 /* c */
start local 7 // io.reactivex.CompletableSource c
24: .line 78
goto 30
end local 7 // io.reactivex.CompletableSource c
StackMap locals:
StackMap stack: java.lang.Throwable
25: astore 8 /* e */
start local 8 // java.lang.Throwable e
26: .line 79
aload 8 /* e */
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
27: .line 80
aload 2 /* set */
invokevirtual io.reactivex.disposables.CompositeDisposable.dispose:()V
28: .line 81
aload 5 /* shared */
aload 8 /* e */
invokevirtual io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver.onError:(Ljava/lang/Throwable;)V
29: .line 82
return
end local 8 // java.lang.Throwable e
start local 7 // io.reactivex.CompletableSource c
30: .line 85
StackMap locals: io.reactivex.CompletableSource
StackMap stack:
aload 2 /* set */
invokevirtual io.reactivex.disposables.CompositeDisposable.isDisposed:()Z
ifeq 32
31: .line 86
return
32: .line 89
StackMap locals:
StackMap stack:
aload 4 /* wip */
invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
pop
33: .line 91
aload 7 /* c */
aload 5 /* shared */
invokeinterface io.reactivex.CompletableSource.subscribe:(Lio/reactivex/CompletableObserver;)V
end local 7 // io.reactivex.CompletableSource c
end local 6 // boolean b
34: .line 51
goto 10
35: .line 94
StackMap locals:
StackMap stack:
aload 5 /* shared */
invokevirtual io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver.onComplete:()V
36: .line 95
return
end local 5 // io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver shared
end local 4 // java.util.concurrent.atomic.AtomicInteger wip
end local 3 // java.util.Iterator iterator
end local 2 // io.reactivex.disposables.CompositeDisposable set
end local 1 // io.reactivex.CompletableObserver observer
end local 0 // io.reactivex.internal.operators.completable.CompletableMergeIterable this
LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lio/reactivex/internal/operators/completable/CompletableMergeIterable;
0 37 1 observer Lio/reactivex/CompletableObserver;
1 37 2 set Lio/reactivex/disposables/CompositeDisposable;
3 4 3 iterator Ljava/util/Iterator<+Lio/reactivex/CompletableSource;>;
8 37 3 iterator Ljava/util/Iterator<+Lio/reactivex/CompletableSource;>;
5 8 4 e Ljava/lang/Throwable;
9 37 4 wip Ljava/util/concurrent/atomic/AtomicInteger;
10 37 5 shared Lio/reactivex/internal/operators/completable/CompletableMergeIterable$MergeCompletableObserver;
13 14 6 b Z
19 34 6 b Z
15 19 7 e Ljava/lang/Throwable;
24 25 7 c Lio/reactivex/CompletableSource;
30 34 7 c Lio/reactivex/CompletableSource;
26 30 8 e Ljava/lang/Throwable;
Exception table:
from to target type
2 3 4 Class java.lang.Throwable
12 13 14 Class java.lang.Throwable
23 24 25 Class java.lang.Throwable
MethodParameters:
Name Flags
observer final
}
SourceFile: "CompletableMergeIterable.java"
NestMembers:
io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver
InnerClasses:
final MergeCompletableObserver = io.reactivex.internal.operators.completable.CompletableMergeIterable$MergeCompletableObserver of io.reactivex.internal.operators.completable.CompletableMergeIterable