final class reactor.core.publisher.MonoUsing<T, S> extends reactor.core.publisher.Mono<T> implements reactor.core.Fuseable, reactor.core.publisher.SourceProducer<T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.MonoUsing
super_class: reactor.core.publisher.Mono
{
final java.util.concurrent.Callable<S> resourceSupplier;
descriptor: Ljava/util/concurrent/Callable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/Callable<TS;>;
final java.util.function.Function<? super S, ? extends reactor.core.publisher.Mono<? extends T>> sourceFactory;
descriptor: Ljava/util/function/Function;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Function<-TS;+Lreactor/core/publisher/Mono<+TT;>;>;
final java.util.function.Consumer<? super S> resourceCleanup;
descriptor: Ljava/util/function/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Consumer<-TS;>;
final boolean eager;
descriptor: Z
flags: (0x0010) ACC_FINAL
void <init>(java.util.concurrent.Callable<S>, java.util.function.Function<? super S, ? extends reactor.core.publisher.Mono<? extends T>>, java.util.function.Consumer<? super S>, );
descriptor: (Ljava/util/concurrent/Callable;Ljava/util/function/Function;Ljava/util/function/Consumer;Z)V
flags: (0x0000)
Code:
stack=3, 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.Mono.<init>:()V
1: aload 0
2: aload 1
ldc "resourceSupplier"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.concurrent.Callable
3: putfield reactor.core.publisher.MonoUsing.resourceSupplier:Ljava/util/concurrent/Callable;
4: aload 0
aload 2
ldc "sourceFactory"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Function
putfield reactor.core.publisher.MonoUsing.sourceFactory:Ljava/util/function/Function;
5: aload 0
aload 3
ldc "resourceCleanup"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Consumer
putfield reactor.core.publisher.MonoUsing.resourceCleanup:Ljava/util/function/Consumer;
6: aload 0
iload 4
putfield reactor.core.publisher.MonoUsing.eager:Z
7: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lreactor/core/publisher/MonoUsing<TT;TS;>;
0 8 1 resourceSupplier Ljava/util/concurrent/Callable<TS;>;
0 8 2 sourceFactory Ljava/util/function/Function<-TS;+Lreactor/core/publisher/Mono<+TT;>;>;
0 8 3 resourceCleanup Ljava/util/function/Consumer<-TS;>;
0 8 4 eager Z
Signature: (Ljava/util/concurrent/Callable<TS;>;Ljava/util/function/Function<-TS;+Lreactor/core/publisher/Mono<+TT;>;>;Ljava/util/function/Consumer<-TS;>;Z)V
MethodParameters:
Name Flags
resourceSupplier
sourceFactory
resourceCleanup
eager
public void subscribe(reactor.core.CoreSubscriber<? super T>);
descriptor: (Lreactor/core/CoreSubscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.MonoUsing.resourceSupplier:Ljava/util/concurrent/Callable;
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
astore 2
start local 2 1: goto 5
end local 2 2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
start local 3 3: aload 1
aload 3
aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
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
4: return
end local 3 start local 2 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield reactor.core.publisher.MonoUsing.sourceFactory:Ljava/util/function/Function;
aload 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
6: ldc "The sourceFactory returned a null value"
7: invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast reactor.core.publisher.Mono
astore 3
start local 3 8: goto 16
end local 3 9: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
start local 4 10: aload 0
getfield reactor.core.publisher.MonoUsing.resourceCleanup:Ljava/util/function/Consumer;
aload 2
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
11: goto 14
12: StackMap locals: reactor.core.publisher.MonoUsing reactor.core.CoreSubscriber java.lang.Object top java.lang.Throwable
StackMap stack: java.lang.Throwable
astore 5
start local 5 13: aload 5
aload 4
aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
invokestatic reactor.core.publisher.Operators.onOperatorError:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokestatic reactor.core.Exceptions.addSuppressed:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 4
end local 5 14: StackMap locals:
StackMap stack:
aload 1
aload 4
aload 1
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
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
15: return
end local 4 start local 3 16: StackMap locals: reactor.core.publisher.MonoUsing reactor.core.CoreSubscriber java.lang.Object reactor.core.publisher.Mono
StackMap stack:
aload 3
instanceof reactor.core.Fuseable
ifeq 24
17: aload 3
new reactor.core.publisher.MonoUsing$MonoUsingSubscriber
dup
aload 1
18: aload 0
getfield reactor.core.publisher.MonoUsing.resourceCleanup:Ljava/util/function/Consumer;
19: aload 2
20: aload 0
getfield reactor.core.publisher.MonoUsing.eager:Z
21: iconst_1
invokespecial reactor.core.publisher.MonoUsing$MonoUsingSubscriber.<init>:(Lreactor/core/CoreSubscriber;Ljava/util/function/Consumer;Ljava/lang/Object;ZZ)V
22: invokevirtual reactor.core.publisher.Mono.subscribe:(Lreactor/core/CoreSubscriber;)V
23: goto 30
24: StackMap locals:
StackMap stack:
aload 3
new reactor.core.publisher.MonoUsing$MonoUsingSubscriber
dup
aload 1
25: aload 0
getfield reactor.core.publisher.MonoUsing.resourceCleanup:Ljava/util/function/Consumer;
26: aload 2
27: aload 0
getfield reactor.core.publisher.MonoUsing.eager:Z
28: iconst_0
invokespecial reactor.core.publisher.MonoUsing$MonoUsingSubscriber.<init>:(Lreactor/core/CoreSubscriber;Ljava/util/function/Consumer;Ljava/lang/Object;ZZ)V
29: invokevirtual reactor.core.publisher.Mono.subscribe:(Lreactor/core/CoreSubscriber;)V
30: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 31 0 this Lreactor/core/publisher/MonoUsing<TT;TS;>;
0 31 1 actual Lreactor/core/CoreSubscriber<-TT;>;
1 2 2 resource TS;
5 31 2 resource TS;
3 5 3 e Ljava/lang/Throwable;
8 9 3 p Lreactor/core/publisher/Mono<+TT;>;
16 31 3 p Lreactor/core/publisher/Mono<+TT;>;
10 16 4 e Ljava/lang/Throwable;
13 14 5 ex Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
5 8 9 Class java.lang.Throwable
10 11 12 Class java.lang.Throwable
Signature: (Lreactor/core/CoreSubscriber<-TT;>;)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.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:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/MonoUsing<TT;TS;>;
0 2 1 key Lreactor/core/Scannable$Attr;
MethodParameters:
Name Flags
key
}
Signature: <T:Ljava/lang/Object;S:Ljava/lang/Object;>Lreactor/core/publisher/Mono<TT;>;Lreactor/core/Fuseable;Lreactor/core/publisher/SourceProducer<TT;>;
SourceFile: "MonoUsing.java"
NestMembers:
reactor.core.publisher.MonoUsing$MonoUsingSubscriber
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 MonoUsingSubscriber = reactor.core.publisher.MonoUsing$MonoUsingSubscriber of reactor.core.publisher.MonoUsing