abstract class reactor.core.publisher.FluxFromMonoOperator<I, O> extends reactor.core.publisher.Flux<O> implements reactor.core.Scannable, reactor.core.publisher.OptimizableOperator<O, I>
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: reactor.core.publisher.FluxFromMonoOperator
super_class: reactor.core.publisher.Flux
{
protected final reactor.core.publisher.Mono<? extends I> source;
descriptor: Lreactor/core/publisher/Mono;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Lreactor/core/publisher/Mono<+TI;>;
final reactor.core.publisher.OptimizableOperator<?, I> optimizableOperator;
descriptor: Lreactor/core/publisher/OptimizableOperator;
flags: (0x0010) ACC_FINAL
Signature: Lreactor/core/publisher/OptimizableOperator<*TI;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
protected void <init>(reactor.core.publisher.Mono<? extends I>);
descriptor: (Lreactor/core/publisher/Mono;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokespecial reactor.core.publisher.Flux.<init>:()V
1: aload 0
aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
putfield reactor.core.publisher.FluxFromMonoOperator.source:Lreactor/core/publisher/Mono;
2: aload 1
instanceof reactor.core.publisher.OptimizableOperator
ifeq 6
3: aload 1
checkcast reactor.core.publisher.OptimizableOperator
astore 2
start local 2 4: aload 0
aload 2
putfield reactor.core.publisher.FluxFromMonoOperator.optimizableOperator:Lreactor/core/publisher/OptimizableOperator;
end local 2 5: goto 7
6: StackMap locals: reactor.core.publisher.FluxFromMonoOperator reactor.core.publisher.Mono
StackMap stack:
aload 0
aconst_null
putfield reactor.core.publisher.FluxFromMonoOperator.optimizableOperator:Lreactor/core/publisher/OptimizableOperator;
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lreactor/core/publisher/FluxFromMonoOperator<TI;TO;>;
0 8 1 source Lreactor/core/publisher/Mono<+TI;>;
4 5 2 optimSource Lreactor/core/publisher/OptimizableOperator<*TI;>;
Signature: (Lreactor/core/publisher/Mono<+TI;>;)V
MethodParameters:
Name Flags
source
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
invokevirtual reactor.core.publisher.FluxFromMonoOperator.getPrefetch:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
1: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.PARENT:Lreactor/core/Scannable$Attr;
if_acmpne 2
aload 0
getfield reactor.core.publisher.FluxFromMonoOperator.source:Lreactor/core/publisher/Mono;
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/FluxFromMonoOperator<TI;TO;>;
0 3 1 key Lreactor/core/Scannable$Attr;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
key
public final void subscribe(reactor.core.CoreSubscriber<? super O>);
descriptor: (Lreactor/core/CoreSubscriber;)V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
astore 2
start local 2 1: StackMap locals: reactor.core.publisher.OptimizableOperator
StackMap stack:
aload 2
aload 1
invokeinterface reactor.core.publisher.OptimizableOperator.subscribeOrReturn:(Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
astore 1
2: aload 1
ifnonnull 4
3: return
4: StackMap locals:
StackMap stack:
aload 2
invokeinterface reactor.core.publisher.OptimizableOperator.nextOptimizableSource:()Lreactor/core/publisher/OptimizableOperator;
astore 3
start local 3 5: aload 3
ifnonnull 8
6: aload 2
invokeinterface reactor.core.publisher.OptimizableOperator.source:()Lreactor/core/CorePublisher;
aload 1
invokeinterface reactor.core.CorePublisher.subscribe:(Lreactor/core/CoreSubscriber;)V
7: return
8: StackMap locals: reactor.core.publisher.OptimizableOperator
StackMap stack:
aload 3
astore 2
end local 3 9: goto 1
10: StackMap locals: reactor.core.publisher.FluxFromMonoOperator reactor.core.CoreSubscriber reactor.core.publisher.OptimizableOperator
StackMap stack: java.lang.Throwable
astore 3
start local 3 11: aload 1
aload 3
invokestatic reactor.core.publisher.Operators.reportThrowInSubscribe:(Lreactor/core/CoreSubscriber;Ljava/lang/Throwable;)V
12: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lreactor/core/publisher/FluxFromMonoOperator<TI;TO;>;
0 13 1 subscriber Lreactor/core/CoreSubscriber<-TO;>;
1 13 2 operator Lreactor/core/publisher/OptimizableOperator;
5 9 3 newSource Lreactor/core/publisher/OptimizableOperator;
11 13 3 e Ljava/lang/Throwable;
Exception table:
from to target type
1 3 10 Class java.lang.Throwable
4 7 10 Class java.lang.Throwable
8 10 10 Class java.lang.Throwable
Signature: (Lreactor/core/CoreSubscriber<-TO;>;)V
MethodParameters:
Name Flags
subscriber
public abstract reactor.core.CoreSubscriber<? super I> subscribeOrReturn(reactor.core.CoreSubscriber<? super O>);
descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Exceptions:
throws java.lang.Throwable
Signature: (Lreactor/core/CoreSubscriber<-TO;>;)Lreactor/core/CoreSubscriber<-TI;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
actual
public final reactor.core.CorePublisher<? extends I> source();
descriptor: ()Lreactor/core/CorePublisher;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxFromMonoOperator.source:Lreactor/core/publisher/Mono;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxFromMonoOperator<TI;TO;>;
Signature: ()Lreactor/core/CorePublisher<+TI;>;
public final reactor.core.publisher.OptimizableOperator<?, ? extends I> nextOptimizableSource();
descriptor: ()Lreactor/core/publisher/OptimizableOperator;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxFromMonoOperator.optimizableOperator:Lreactor/core/publisher/OptimizableOperator;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxFromMonoOperator<TI;TO;>;
Signature: ()Lreactor/core/publisher/OptimizableOperator<*+TI;>;
}
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>Lreactor/core/publisher/Flux<TO;>;Lreactor/core/Scannable;Lreactor/core/publisher/OptimizableOperator<TO;TI;>;
SourceFile: "FluxFromMonoOperator.java"
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable