final class reactor.core.publisher.FluxMergeSequential<T, R> extends reactor.core.publisher.InternalFluxOperator<T, R>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxMergeSequential
super_class: reactor.core.publisher.InternalFluxOperator
{
final reactor.core.publisher.FluxConcatMap$ErrorMode errorMode;
descriptor: Lreactor/core/publisher/FluxConcatMap$ErrorMode;
flags: (0x0010) ACC_FINAL
Signature: Lreactor/core/publisher/FluxConcatMap$ErrorMode;
final java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper;
descriptor: Ljava/util/function/Function;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
final int maxConcurrency;
descriptor: I
flags: (0x0010) ACC_FINAL
final int prefetch;
descriptor: I
flags: (0x0010) ACC_FINAL
final java.util.function.Supplier<java.util.Queue<reactor.core.publisher.FluxMergeSequential$MergeSequentialInner<R>>> queueSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Supplier<Ljava/util/Queue<Lreactor/core/publisher/FluxMergeSequential$MergeSequentialInner<TR;>;>;>;
void <init>(reactor.core.publisher.Flux<? extends T>, java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int, int, reactor.core.publisher.FluxConcatMap$ErrorMode);
descriptor: (Lreactor/core/publisher/Flux;Ljava/util/function/Function;IILreactor/core/publisher/FluxConcatMap$ErrorMode;)V
flags: (0x0000)
Code:
stack=8, 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
aload 1
aload 2
iload 3
iload 4
aload 5
1: iload 4
iload 3
invokestatic java.lang.Math.max:(II)I
invokestatic reactor.util.concurrent.Queues.get:(I)Ljava/util/function/Supplier;
invokespecial reactor.core.publisher.FluxMergeSequential.<init>:(Lreactor/core/publisher/Flux;Ljava/util/function/Function;IILreactor/core/publisher/FluxConcatMap$ErrorMode;Ljava/util/function/Supplier;)V
2: 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 3 0 this Lreactor/core/publisher/FluxMergeSequential<TT;TR;>;
0 3 1 source Lreactor/core/publisher/Flux<+TT;>;
0 3 2 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 3 3 maxConcurrency I
0 3 4 prefetch I
0 3 5 errorMode Lreactor/core/publisher/FluxConcatMap$ErrorMode;
Signature: (Lreactor/core/publisher/Flux<+TT;>;Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;IILreactor/core/publisher/FluxConcatMap$ErrorMode;)V
MethodParameters:
Name Flags
source
mapper
maxConcurrency
prefetch
errorMode
void <init>(reactor.core.publisher.Flux<? extends T>, java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, int, int, reactor.core.publisher.FluxConcatMap$ErrorMode, java.util.function.Supplier<java.util.Queue<reactor.core.publisher.FluxMergeSequential$MergeSequentialInner<R>>>);
descriptor: (Lreactor/core/publisher/Flux;Ljava/util/function/Function;IILreactor/core/publisher/FluxConcatMap$ErrorMode;Ljava/util/function/Supplier;)V
flags: (0x0000)
Code:
stack=5, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
invokespecial reactor.core.publisher.InternalFluxOperator.<init>:(Lreactor/core/publisher/Flux;)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.FluxMergeSequential reactor.core.publisher.Flux java.util.function.Function int int reactor.core.publisher.FluxConcatMap$ErrorMode java.util.function.Supplier
StackMap stack:
iload 3
ifgt 5
4: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "maxConcurrency > 0 required but it was "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 3
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
5: StackMap locals:
StackMap stack:
aload 0
aload 2
ldc "mapper"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Function
putfield reactor.core.publisher.FluxMergeSequential.mapper:Ljava/util/function/Function;
6: aload 0
iload 3
putfield reactor.core.publisher.FluxMergeSequential.maxConcurrency:I
7: aload 0
iload 4
putfield reactor.core.publisher.FluxMergeSequential.prefetch:I
8: aload 0
aload 5
putfield reactor.core.publisher.FluxMergeSequential.errorMode:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
9: aload 0
aload 6
putfield reactor.core.publisher.FluxMergeSequential.queueSupplier:Ljava/util/function/Supplier;
10: return
end local 6 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 11 0 this Lreactor/core/publisher/FluxMergeSequential<TT;TR;>;
0 11 1 source Lreactor/core/publisher/Flux<+TT;>;
0 11 2 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 11 3 maxConcurrency I
0 11 4 prefetch I
0 11 5 errorMode Lreactor/core/publisher/FluxConcatMap$ErrorMode;
0 11 6 queueSupplier Ljava/util/function/Supplier<Ljava/util/Queue<Lreactor/core/publisher/FluxMergeSequential$MergeSequentialInner<TR;>;>;>;
Signature: (Lreactor/core/publisher/Flux<+TT;>;Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;IILreactor/core/publisher/FluxConcatMap$ErrorMode;Ljava/util/function/Supplier<Ljava/util/Queue<Lreactor/core/publisher/FluxMergeSequential$MergeSequentialInner<TR;>;>;>;)V
MethodParameters:
Name Flags
source
mapper
maxConcurrency
prefetch
errorMode
queueSupplier
public reactor.core.CoreSubscriber<? super T> subscribeOrReturn(reactor.core.CoreSubscriber<? super R>);
descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxMergeSequential.source:Lreactor/core/publisher/Flux;
aload 1
aload 0
getfield reactor.core.publisher.FluxMergeSequential.mapper:Ljava/util/function/Function;
iconst_0
iconst_0
invokestatic reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap:(Lorg/reactivestreams/Publisher;Lreactor/core/CoreSubscriber;Ljava/util/function/Function;ZZ)Z
ifeq 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
new reactor.core.publisher.FluxMergeSequential$MergeSequentialMain
dup
aload 1
3: aload 0
getfield reactor.core.publisher.FluxMergeSequential.mapper:Ljava/util/function/Function;
4: aload 0
getfield reactor.core.publisher.FluxMergeSequential.maxConcurrency:I
5: aload 0
getfield reactor.core.publisher.FluxMergeSequential.prefetch:I
6: aload 0
getfield reactor.core.publisher.FluxMergeSequential.errorMode:Lreactor/core/publisher/FluxConcatMap$ErrorMode;
7: aload 0
getfield reactor.core.publisher.FluxMergeSequential.queueSupplier:Ljava/util/function/Supplier;
8: invokespecial reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.<init>:(Lreactor/core/CoreSubscriber;Ljava/util/function/Function;IILreactor/core/publisher/FluxConcatMap$ErrorMode;Ljava/util/function/Supplier;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lreactor/core/publisher/FluxMergeSequential<TT;TR;>;
0 9 1 actual Lreactor/core/CoreSubscriber<-TR;>;
Signature: (Lreactor/core/CoreSubscriber<-TR;>;)Lreactor/core/CoreSubscriber<-TT;>;
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.RUN_STYLE:Lreactor/core/Scannable$Attr;
if_acmpne 1
getstatic reactor.core.Scannable$Attr$RunStyle.SYNC:Lreactor/core/Scannable$Attr$RunStyle;
areturn
1: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial reactor.core.publisher.InternalFluxOperator.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/FluxMergeSequential<TT;TR;>;
0 2 1 key Lreactor/core/Scannable$Attr;
MethodParameters:
Name Flags
key
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Lreactor/core/publisher/InternalFluxOperator<TT;TR;>;
SourceFile: "FluxMergeSequential.java"
NestMembers:
reactor.core.publisher.FluxMergeSequential$MergeSequentialInner reactor.core.publisher.FluxMergeSequential$MergeSequentialMain
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
public final RunStyle = reactor.core.Scannable$Attr$RunStyle of reactor.core.Scannable$Attr
final ErrorMode = reactor.core.publisher.FluxConcatMap$ErrorMode of reactor.core.publisher.FluxConcatMap
final MergeSequentialInner = reactor.core.publisher.FluxMergeSequential$MergeSequentialInner of reactor.core.publisher.FluxMergeSequential
final MergeSequentialMain = reactor.core.publisher.FluxMergeSequential$MergeSequentialMain of reactor.core.publisher.FluxMergeSequential