public class org.springframework.core.ReactiveAdapter
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.springframework.core.ReactiveAdapter
super_class: java.lang.Object
{
private final org.springframework.core.ReactiveTypeDescriptor descriptor;
descriptor: Lorg/springframework/core/ReactiveTypeDescriptor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.function.Function<java.lang.Object, org.reactivestreams.Publisher<?>> toPublisherFunction;
descriptor: Ljava/util/function/Function;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Function<Ljava/lang/Object;Lorg/reactivestreams/Publisher<*>;>;
private final java.util.function.Function<org.reactivestreams.Publisher<?>, java.lang.Object> fromPublisherFunction;
descriptor: Ljava/util/function/Function;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Function<Lorg/reactivestreams/Publisher<*>;Ljava/lang/Object;>;
public void <init>(org.springframework.core.ReactiveTypeDescriptor, java.util.function.Function<java.lang.Object, org.reactivestreams.Publisher<?>>, java.util.function.Function<org.reactivestreams.Publisher<?>, java.lang.Object>);
descriptor: (Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 1
ldc "'descriptor' is required"
invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
2: aload 2
ldc "'toPublisherFunction' is required"
invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
3: aload 3
ldc "'fromPublisherFunction' is required"
invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
4: aload 0
aload 1
putfield org.springframework.core.ReactiveAdapter.descriptor:Lorg/springframework/core/ReactiveTypeDescriptor;
5: aload 0
aload 2
putfield org.springframework.core.ReactiveAdapter.toPublisherFunction:Ljava/util/function/Function;
6: aload 0
aload 3
putfield org.springframework.core.ReactiveAdapter.fromPublisherFunction:Ljava/util/function/Function;
7: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/springframework/core/ReactiveAdapter;
0 8 1 descriptor Lorg/springframework/core/ReactiveTypeDescriptor;
0 8 2 toPublisherFunction Ljava/util/function/Function<Ljava/lang/Object;Lorg/reactivestreams/Publisher<*>;>;
0 8 3 fromPublisherFunction Ljava/util/function/Function<Lorg/reactivestreams/Publisher<*>;Ljava/lang/Object;>;
Signature: (Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function<Ljava/lang/Object;Lorg/reactivestreams/Publisher<*>;>;Ljava/util/function/Function<Lorg/reactivestreams/Publisher<*>;Ljava/lang/Object;>;)V
MethodParameters:
Name Flags
descriptor
toPublisherFunction
fromPublisherFunction
public org.springframework.core.ReactiveTypeDescriptor getDescriptor();
descriptor: ()Lorg/springframework/core/ReactiveTypeDescriptor;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.springframework.core.ReactiveAdapter.descriptor:Lorg/springframework/core/ReactiveTypeDescriptor;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/core/ReactiveAdapter;
public java.lang.Class<?> getReactiveType();
descriptor: ()Ljava/lang/Class;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.springframework.core.ReactiveAdapter.getDescriptor:()Lorg/springframework/core/ReactiveTypeDescriptor;
invokevirtual org.springframework.core.ReactiveTypeDescriptor.getReactiveType:()Ljava/lang/Class;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/core/ReactiveAdapter;
Signature: ()Ljava/lang/Class<*>;
public boolean isMultiValue();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.springframework.core.ReactiveAdapter.getDescriptor:()Lorg/springframework/core/ReactiveTypeDescriptor;
invokevirtual org.springframework.core.ReactiveTypeDescriptor.isMultiValue:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/core/ReactiveAdapter;
public boolean supportsEmpty();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.springframework.core.ReactiveAdapter.getDescriptor:()Lorg/springframework/core/ReactiveTypeDescriptor;
invokevirtual org.springframework.core.ReactiveTypeDescriptor.supportsEmpty:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/core/ReactiveAdapter;
public boolean isNoValue();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.springframework.core.ReactiveAdapter.getDescriptor:()Lorg/springframework/core/ReactiveTypeDescriptor;
invokevirtual org.springframework.core.ReactiveTypeDescriptor.isNoValue:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/core/ReactiveAdapter;
public <T> org.reactivestreams.Publisher<T> toPublisher();
descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 2
1: aload 0
invokevirtual org.springframework.core.ReactiveAdapter.getDescriptor:()Lorg/springframework/core/ReactiveTypeDescriptor;
invokevirtual org.springframework.core.ReactiveTypeDescriptor.getEmptyValue:()Ljava/lang/Object;
astore 1
2: StackMap locals:
StackMap stack:
aload 0
getfield org.springframework.core.ReactiveAdapter.toPublisherFunction:Ljava/util/function/Function;
aload 1
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/springframework/core/ReactiveAdapter;
0 3 1 source Ljava/lang/Object;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Object;)Lorg/reactivestreams/Publisher<TT;>;
RuntimeVisibleParameterAnnotations:
0:
org.springframework.lang.Nullable()
MethodParameters:
Name Flags
source
public fromPublisher(org.reactivestreams.Publisher<?>);
descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.springframework.core.ReactiveAdapter.fromPublisherFunction:Ljava/util/function/Function;
aload 1
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 Lorg/springframework/core/ReactiveAdapter;
0 1 1 publisher Lorg/reactivestreams/Publisher<*>;
Signature: (Lorg/reactivestreams/Publisher<*>;)Ljava/lang/Object;
MethodParameters:
Name Flags
publisher
}
SourceFile: "ReactiveAdapter.java"