final class reactor.core.publisher.FluxCombineLatest<T, R> extends reactor.core.publisher.Flux<R> implements reactor.core.Fuseable, reactor.core.publisher.SourceProducer<R>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxCombineLatest
super_class: reactor.core.publisher.Flux
{
final org.reactivestreams.Publisher<? extends T>[] array;
descriptor: [Lorg/reactivestreams/Publisher;
flags: (0x0010) ACC_FINAL
Signature: [Lorg/reactivestreams/Publisher<+TT;>;
final java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> iterable;
descriptor: Ljava/lang/Iterable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;
final java.util.function.Function<java.lang.Object[], R> combiner;
descriptor: Ljava/util/function/Function;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Function<[Ljava/lang/Object;TR;>;
final java.util.function.Supplier<? extends java.util.Queue<reactor.core.publisher.FluxCombineLatest$SourceAndArray>> queueSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Supplier<+Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;>;
final int prefetch;
descriptor: I
flags: (0x0010) ACC_FINAL
void <init>(org.reactivestreams.Publisher<? extends T>[], java.util.function.Function<java.lang.Object[], R>, java.util.function.Supplier<? extends java.util.Queue<reactor.core.publisher.FluxCombineLatest$SourceAndArray>>, );
descriptor: ([Lorg/reactivestreams/Publisher;Ljava/util/function/Function;Ljava/util/function/Supplier;I)V
flags: (0x0000)
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial reactor.core.publisher.Flux.<init>:()V
1: iload 4
ifgt 3
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "prefetch > 0 required but it was "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 4
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: reactor.core.publisher.FluxCombineLatest org.reactivestreams.Publisher[] java.util.function.Function java.util.function.Supplier int
StackMap stack:
aload 0
aload 1
ldc "array"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher[]
putfield reactor.core.publisher.FluxCombineLatest.array:[Lorg/reactivestreams/Publisher;
4: aload 0
aconst_null
putfield reactor.core.publisher.FluxCombineLatest.iterable:Ljava/lang/Iterable;
5: aload 0
aload 2
ldc "combiner"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Function
putfield reactor.core.publisher.FluxCombineLatest.combiner:Ljava/util/function/Function;
6: aload 0
aload 3
ldc "queueSupplier"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Supplier
putfield reactor.core.publisher.FluxCombineLatest.queueSupplier:Ljava/util/function/Supplier;
7: aload 0
iload 4
putfield reactor.core.publisher.FluxCombineLatest.prefetch:I
8: return
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 Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
0 9 1 array [Lorg/reactivestreams/Publisher;
0 9 2 combiner Ljava/util/function/Function<[Ljava/lang/Object;TR;>;
0 9 3 queueSupplier Ljava/util/function/Supplier<+Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;>;
0 9 4 prefetch I
Signature: ([Lorg/reactivestreams/Publisher<+TT;>;Ljava/util/function/Function<[Ljava/lang/Object;TR;>;Ljava/util/function/Supplier<+Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;>;I)V
MethodParameters:
Name Flags
array
combiner
queueSupplier
prefetch
void <init>(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>, java.util.function.Function<java.lang.Object[], R>, java.util.function.Supplier<? extends java.util.Queue<reactor.core.publisher.FluxCombineLatest$SourceAndArray>>, );
descriptor: (Ljava/lang/Iterable;Ljava/util/function/Function;Ljava/util/function/Supplier;I)V
flags: (0x0000)
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial reactor.core.publisher.Flux.<init>:()V
1: iload 4
ifge 3
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "prefetch > 0 required but it was "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 4
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: reactor.core.publisher.FluxCombineLatest java.lang.Iterable java.util.function.Function java.util.function.Supplier int
StackMap stack:
aload 0
aconst_null
putfield reactor.core.publisher.FluxCombineLatest.array:[Lorg/reactivestreams/Publisher;
4: aload 0
aload 1
ldc "iterable"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.lang.Iterable
putfield reactor.core.publisher.FluxCombineLatest.iterable:Ljava/lang/Iterable;
5: aload 0
aload 2
ldc "combiner"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Function
putfield reactor.core.publisher.FluxCombineLatest.combiner:Ljava/util/function/Function;
6: aload 0
aload 3
ldc "queueSupplier"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Supplier
putfield reactor.core.publisher.FluxCombineLatest.queueSupplier:Ljava/util/function/Supplier;
7: aload 0
iload 4
putfield reactor.core.publisher.FluxCombineLatest.prefetch:I
8: return
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 Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
0 9 1 iterable Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;
0 9 2 combiner Ljava/util/function/Function<[Ljava/lang/Object;TR;>;
0 9 3 queueSupplier Ljava/util/function/Supplier<+Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;>;
0 9 4 prefetch I
Signature: (Ljava/lang/Iterable<+Lorg/reactivestreams/Publisher<+TT;>;>;Ljava/util/function/Function<[Ljava/lang/Object;TR;>;Ljava/util/function/Supplier<+Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;>;I)V
MethodParameters:
Name Flags
iterable
combiner
queueSupplier
prefetch
public int getPrefetch();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxCombineLatest.prefetch:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
public void subscribe(reactor.core.CoreSubscriber<? super R>);
descriptor: (Lreactor/core/CoreSubscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxCombineLatest.array:[Lorg/reactivestreams/Publisher;
astore 2
start local 2 1: aload 2
ifnonnull 35
2: iconst_0
istore 3
start local 3 3: bipush 8
anewarray org.reactivestreams.Publisher
astore 2
4: aload 0
getfield reactor.core.publisher.FluxCombineLatest.iterable:Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
ldc "The iterator returned is null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.Iterator
astore 4
start local 4 5: goto 11
end local 4 6: StackMap locals: reactor.core.publisher.FluxCombineLatest reactor.core.CoreSubscriber org.reactivestreams.Publisher[] int
StackMap stack: java.lang.Throwable
astore 5
start local 5 7: aload 1
aload 5
8: aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
9: invokestatic reactor.core.publisher.Operators.onOperatorError:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
10: return
end local 5 start local 4 11: StackMap locals: java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
istore 5
start local 5 12: goto 18
end local 5 13: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
start local 6 14: aload 1
aload 6
15: aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
16: invokestatic reactor.core.publisher.Operators.onOperatorError:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
17: return
end local 6 start local 5 18: StackMap locals: int
StackMap stack:
iload 5
ifne 20
19: goto 36
20: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
21: ldc "The Publisher returned by the iterator is null"
22: invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
astore 6
start local 6 23: goto 29
end local 6 24: StackMap locals:
StackMap stack: java.lang.Throwable
astore 7
start local 7 25: aload 1
aload 7
26: aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
27: invokestatic reactor.core.publisher.Operators.onOperatorError:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
28: return
end local 7 start local 6 29: StackMap locals: org.reactivestreams.Publisher
StackMap stack:
iload 3
aload 2
arraylength
if_icmpne 33
30: iload 3
iload 3
iconst_2
ishr
iadd
anewarray org.reactivestreams.Publisher
astore 7
start local 7 31: aload 2
iconst_0
aload 7
iconst_0
iload 3
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
32: aload 7
astore 2
end local 7 33: StackMap locals:
StackMap stack:
aload 2
iload 3
iinc 3 1
aload 6
aastore
end local 6 end local 5 34: goto 11
end local 4 end local 3 35: StackMap locals: reactor.core.publisher.FluxCombineLatest reactor.core.CoreSubscriber org.reactivestreams.Publisher[]
StackMap stack:
aload 2
arraylength
istore 3
start local 3 36: StackMap locals: int
StackMap stack:
iload 3
ifne 39
37: aload 1
invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
38: return
39: StackMap locals:
StackMap stack:
iload 3
iconst_1
if_icmpne 47
40: aload 0
invokedynamic apply(Lreactor/core/publisher/FluxCombineLatest;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
reactor/core/publisher/FluxCombineLatest.lambda$0(Ljava/lang/Object;)Ljava/lang/Object; (7)
(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 41: aload 2
iconst_0
aaload
instanceof reactor.core.Fuseable
ifeq 44
42: new reactor.core.publisher.FluxMapFuseable
dup
aload 2
iconst_0
aaload
invokestatic reactor.core.publisher.FluxCombineLatest.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
aload 4
invokespecial reactor.core.publisher.FluxMapFuseable.<init>:(Lreactor/core/publisher/Flux;Ljava/util/function/Function;)V
aload 1
invokevirtual reactor.core.publisher.FluxMapFuseable.subscribe:(Lreactor/core/CoreSubscriber;)V
43: return
44: StackMap locals: java.util.function.Function
StackMap stack:
aload 1
instanceof reactor.core.Fuseable$QueueSubscription
ifne 47
45: new reactor.core.publisher.FluxMap
dup
aload 2
iconst_0
aaload
invokestatic reactor.core.publisher.FluxCombineLatest.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
aload 4
invokespecial reactor.core.publisher.FluxMap.<init>:(Lreactor/core/publisher/Flux;Ljava/util/function/Function;)V
aload 1
invokevirtual reactor.core.publisher.FluxMap.subscribe:(Lreactor/core/CoreSubscriber;)V
46: return
end local 4 47: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxCombineLatest.queueSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Queue
astore 4
start local 4 48: new reactor.core.publisher.FluxCombineLatest$CombineLatestCoordinator
dup
aload 1
aload 0
getfield reactor.core.publisher.FluxCombineLatest.combiner:Ljava/util/function/Function;
iload 3
aload 4
aload 0
getfield reactor.core.publisher.FluxCombineLatest.prefetch:I
invokespecial reactor.core.publisher.FluxCombineLatest$CombineLatestCoordinator.<init>:(Lreactor/core/CoreSubscriber;Ljava/util/function/Function;ILjava/util/Queue;I)V
49: astore 5
start local 5 50: aload 1
aload 5
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
51: aload 5
aload 2
iload 3
invokevirtual reactor.core.publisher.FluxCombineLatest$CombineLatestCoordinator.subscribe:([Lorg/reactivestreams/Publisher;I)V
52: 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 53 0 this Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
0 53 1 actual Lreactor/core/CoreSubscriber<-TR;>;
1 53 2 a [Lorg/reactivestreams/Publisher;
3 35 3 n I
36 53 3 n I
5 6 4 it Ljava/util/Iterator<+Lorg/reactivestreams/Publisher<+TT;>;>;
11 35 4 it Ljava/util/Iterator<+Lorg/reactivestreams/Publisher<+TT;>;>;
7 11 5 e Ljava/lang/Throwable;
12 13 5 b Z
18 34 5 b Z
14 18 6 e Ljava/lang/Throwable;
23 24 6 p Lorg/reactivestreams/Publisher<+TT;>;
29 34 6 p Lorg/reactivestreams/Publisher<+TT;>;
25 29 7 e Ljava/lang/Throwable;
31 33 7 c [Lorg/reactivestreams/Publisher;
41 47 4 f Ljava/util/function/Function<TT;TR;>;
48 53 4 queue Ljava/util/Queue<Lreactor/core/publisher/FluxCombineLatest$SourceAndArray;>;
50 53 5 coordinator Lreactor/core/publisher/FluxCombineLatest$CombineLatestCoordinator<TT;TR;>;
Exception table:
from to target type
4 5 6 Class java.lang.Throwable
11 12 13 Class java.lang.Throwable
20 23 24 Class java.lang.Throwable
Signature: (Lreactor/core/CoreSubscriber<-TR;>;)V
MethodParameters:
Name Flags
actual
public java.lang.Object scanUnsafe(reactor.core.Scannable$Attr);
descriptor: (Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
getstatic reactor.core.Scannable$Attr.PREFETCH:Lreactor/core/Scannable$Attr;
if_acmpne 1
aload 0
getfield reactor.core.publisher.FluxCombineLatest.prefetch:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
1: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.RUN_STYLE:Lreactor/core/Scannable$Attr;
if_acmpne 2
getstatic reactor.core.Scannable$Attr$RunStyle.SYNC:Lreactor/core/Scannable$Attr$RunStyle;
areturn
2: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
0 3 1 key Lreactor/core/Scannable$Attr;
MethodParameters:
Name Flags
key
private java.lang.Object lambda$0(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxCombineLatest.combiner:Ljava/util/function/Function;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxCombineLatest<TT;TR;>;
0 1 1 t TT;
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Lreactor/core/publisher/Flux<TR;>;Lreactor/core/Fuseable;Lreactor/core/publisher/SourceProducer<TR;>;
SourceFile: "FluxCombineLatest.java"
NestMembers:
reactor.core.publisher.FluxCombineLatest$CombineLatestCoordinator reactor.core.publisher.FluxCombineLatest$CombineLatestInner reactor.core.publisher.FluxCombineLatest$SourceAndArray
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract QueueSubscription = reactor.core.Fuseable$QueueSubscription of reactor.core.Fuseable
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
public final RunStyle = reactor.core.Scannable$Attr$RunStyle of reactor.core.Scannable$Attr
final CombineLatestCoordinator = reactor.core.publisher.FluxCombineLatest$CombineLatestCoordinator of reactor.core.publisher.FluxCombineLatest
final CombineLatestInner = reactor.core.publisher.FluxCombineLatest$CombineLatestInner of reactor.core.publisher.FluxCombineLatest
final SourceAndArray = reactor.core.publisher.FluxCombineLatest$SourceAndArray of reactor.core.publisher.FluxCombineLatest