public final class io.reactivex.internal.operators.flowable.FlowableZip<T, R> extends io.reactivex.Flowable<R>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.flowable.FlowableZip
super_class: io.reactivex.Flowable
{
final org.reactivestreams.Publisher<? extends T>[] sources;
descriptor: [Lorg/reactivestreams/Publisher;
flags: (0x0010) ACC_FINAL
Signature: [Lorg/reactivestreams/Publisher<+TT;>;
final java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sourcesIterable;
descriptor: Ljava/lang/Iterable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;
final io.reactivex.functions.Function<? super java.lang.Object[], ? extends R> zipper;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;
final int bufferSize;
descriptor: I
flags: (0x0010) ACC_FINAL
final boolean delayError;
descriptor: Z
flags: (0x0010) ACC_FINAL
public void <init>(org.reactivestreams.Publisher<? extends T>[], java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>, io.reactivex.functions.Function<? super java.lang.Object[], ? extends R>, int, );
descriptor: ([Lorg/reactivestreams/Publisher;Ljava/lang/Iterable;Lio/reactivex/functions/Function;IZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, 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 io.reactivex.Flowable.<init>:()V
1: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableZip.sources:[Lorg/reactivestreams/Publisher;
2: aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableZip.sourcesIterable:Ljava/lang/Iterable;
3: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableZip.zipper:Lio/reactivex/functions/Function;
4: aload 0
iload 4
putfield io.reactivex.internal.operators.flowable.FlowableZip.bufferSize:I
5: aload 0
iload 5
putfield io.reactivex.internal.operators.flowable.FlowableZip.delayError:Z
6: 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 7 0 this Lio/reactivex/internal/operators/flowable/FlowableZip<TT;TR;>;
0 7 1 sources [Lorg/reactivestreams/Publisher;
0 7 2 sourcesIterable Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;
0 7 3 zipper Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;
0 7 4 bufferSize I
0 7 5 delayError Z
Signature: ([Lorg/reactivestreams/Publisher<+TT;>;Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;IZ)V
MethodParameters:
Name Flags
sources
sourcesIterable
zipper
bufferSize
delayError
public void subscribeActual(org.reactivestreams.Subscriber<? super R>);
descriptor: (Lorg/reactivestreams/Subscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableZip.sources:[Lorg/reactivestreams/Publisher;
astore 2
start local 2 1: iconst_0
istore 3
start local 3 2: aload 2
ifnonnull 13
3: bipush 8
anewarray org.reactivestreams.Publisher
astore 2
4: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableZip.sourcesIterable:Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 5
goto 11
StackMap locals: io.reactivex.internal.operators.flowable.FlowableZip org.reactivestreams.Subscriber org.reactivestreams.Publisher[] int top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
astore 4
start local 4 6: iload 3
aload 2
arraylength
if_icmpne 10
7: iload 3
iload 3
iconst_2
ishr
iadd
anewarray org.reactivestreams.Publisher
astore 6
start local 6 8: aload 2
iconst_0
aload 6
iconst_0
iload 3
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
9: aload 6
astore 2
end local 6 10: StackMap locals: io.reactivex.internal.operators.flowable.FlowableZip org.reactivestreams.Subscriber org.reactivestreams.Publisher[] int org.reactivestreams.Publisher java.util.Iterator
StackMap stack:
aload 2
iload 3
iinc 3 1
aload 4
aastore
end local 4 11: StackMap locals: io.reactivex.internal.operators.flowable.FlowableZip org.reactivestreams.Subscriber org.reactivestreams.Publisher[] int top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
12: goto 14
13: StackMap locals: io.reactivex.internal.operators.flowable.FlowableZip org.reactivestreams.Subscriber org.reactivestreams.Publisher[] int
StackMap stack:
aload 2
arraylength
istore 3
14: StackMap locals:
StackMap stack:
iload 3
ifne 17
15: aload 1
invokestatic io.reactivex.internal.subscriptions.EmptySubscription.complete:(Lorg/reactivestreams/Subscriber;)V
16: return
17: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.flowable.FlowableZip$ZipCoordinator
dup
aload 1
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableZip.zipper:Lio/reactivex/functions/Function;
iload 3
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableZip.bufferSize:I
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableZip.delayError:Z
invokespecial io.reactivex.internal.operators.flowable.FlowableZip$ZipCoordinator.<init>:(Lorg/reactivestreams/Subscriber;Lio/reactivex/functions/Function;IIZ)V
astore 4
start local 4 18: aload 1
aload 4
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
19: aload 4
aload 2
iload 3
invokevirtual io.reactivex.internal.operators.flowable.FlowableZip$ZipCoordinator.subscribe:([Lorg/reactivestreams/Publisher;I)V
20: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/reactivex/internal/operators/flowable/FlowableZip<TT;TR;>;
0 21 1 s Lorg/reactivestreams/Subscriber<-TR;>;
1 21 2 sources [Lorg/reactivestreams/Publisher;
2 21 3 count I
6 11 4 p Lorg/reactivestreams/Publisher<+TT;>;
8 10 6 b [Lorg/reactivestreams/Publisher;
18 21 4 coordinator Lio/reactivex/internal/operators/flowable/FlowableZip$ZipCoordinator<TT;TR;>;
Signature: (Lorg/reactivestreams/Subscriber<-TR;>;)V
MethodParameters:
Name Flags
s
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Lio/reactivex/Flowable<TR;>;
SourceFile: "FlowableZip.java"
NestMembers:
io.reactivex.internal.operators.flowable.FlowableZip$ZipCoordinator io.reactivex.internal.operators.flowable.FlowableZip$ZipSubscriber
InnerClasses:
final ZipCoordinator = io.reactivex.internal.operators.flowable.FlowableZip$ZipCoordinator of io.reactivex.internal.operators.flowable.FlowableZip
final ZipSubscriber = io.reactivex.internal.operators.flowable.FlowableZip$ZipSubscriber of io.reactivex.internal.operators.flowable.FlowableZip