public class reactor.core.Scannable$Attr<T>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: reactor.core.Scannable$Attr
super_class: java.lang.Object
{
public static final reactor.core.Scannable$Attr<reactor.core.Scannable> ACTUAL;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Lreactor/core/Scannable;>;
public static final reactor.core.Scannable$Attr<java.lang.Boolean> ACTUAL_METADATA;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Boolean;>;
public static final reactor.core.Scannable$Attr<java.lang.Integer> BUFFERED;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Integer;>;
public static final reactor.core.Scannable$Attr<java.lang.Integer> CAPACITY;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Integer;>;
public static final reactor.core.Scannable$Attr<java.lang.Boolean> CANCELLED;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Boolean;>;
public static final reactor.core.Scannable$Attr<java.lang.Boolean> DELAY_ERROR;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Boolean;>;
public static final reactor.core.Scannable$Attr<java.lang.Throwable> ERROR;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Throwable;>;
public static final reactor.core.Scannable$Attr<java.lang.Long> LARGE_BUFFERED;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Long;>;
public static final reactor.core.Scannable$Attr<java.lang.String> NAME;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/String;>;
public static final reactor.core.Scannable$Attr<reactor.core.Scannable> PARENT;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Lreactor/core/Scannable;>;
public static final reactor.core.Scannable$Attr<reactor.core.Scannable> RUN_ON;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Lreactor/core/Scannable;>;
public static final reactor.core.Scannable$Attr<java.lang.Integer> PREFETCH;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Integer;>;
public static final reactor.core.Scannable$Attr<java.lang.Long> REQUESTED_FROM_DOWNSTREAM;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Long;>;
public static final reactor.core.Scannable$Attr<java.lang.Boolean> TERMINATED;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/lang/Boolean;>;
public static final reactor.core.Scannable$Attr<java.util.stream.Stream<reactor.util.function.Tuple2<java.lang.String, java.lang.String>>> TAGS;
descriptor: Lreactor/core/Scannable$Attr;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/Scannable$Attr<Ljava/util/stream/Stream<Lreactor/util/function/Tuple2<Ljava/lang/String;Ljava/lang/String;>;>;>;
final T defaultValue;
descriptor: Ljava/lang/Object;
flags: (0x0010) ACC_FINAL
Signature: TT;
final java.util.function.Function<java.lang.Object, ? extends T> safeConverter;
descriptor: Ljava/util/function/Function;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Function<Ljava/lang/Object;+TT;>;
static final reactor.core.Scannable UNAVAILABLE_SCAN;
descriptor: Lreactor/core/Scannable;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final reactor.core.Scannable NULL_SCAN;
descriptor: Lreactor/core/Scannable;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: new reactor.core.Scannable$Attr
dup
aconst_null
1: invokedynamic apply()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/Scannable.from(Ljava/lang/Object;)Lreactor/core/Scannable; (6 itf)
(Ljava/lang/Object;)Lreactor/core/Scannable;
2: invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;Ljava/util/function/Function;)V
putstatic reactor.core.Scannable$Attr.ACTUAL:Lreactor/core/Scannable$Attr;
3: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.ACTUAL_METADATA:Lreactor/core/Scannable$Attr;
4: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.BUFFERED:Lreactor/core/Scannable$Attr;
5: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.CAPACITY:Lreactor/core/Scannable$Attr;
6: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.CANCELLED:Lreactor/core/Scannable$Attr;
7: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.DELAY_ERROR:Lreactor/core/Scannable$Attr;
8: new reactor.core.Scannable$Attr
dup
aconst_null
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.ERROR:Lreactor/core/Scannable$Attr;
9: new reactor.core.Scannable$Attr
dup
aconst_null
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.LARGE_BUFFERED:Lreactor/core/Scannable$Attr;
10: new reactor.core.Scannable$Attr
dup
aconst_null
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.NAME:Lreactor/core/Scannable$Attr;
11: new reactor.core.Scannable$Attr
dup
aconst_null
12: invokedynamic apply()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/Scannable.from(Ljava/lang/Object;)Lreactor/core/Scannable; (6 itf)
(Ljava/lang/Object;)Lreactor/core/Scannable;
13: invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;Ljava/util/function/Function;)V
putstatic reactor.core.Scannable$Attr.PARENT:Lreactor/core/Scannable$Attr;
14: new reactor.core.Scannable$Attr
dup
aconst_null
invokedynamic apply()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/Scannable.from(Ljava/lang/Object;)Lreactor/core/Scannable; (6 itf)
(Ljava/lang/Object;)Lreactor/core/Scannable;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;Ljava/util/function/Function;)V
putstatic reactor.core.Scannable$Attr.RUN_ON:Lreactor/core/Scannable$Attr;
15: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.PREFETCH:Lreactor/core/Scannable$Attr;
16: new reactor.core.Scannable$Attr
dup
lconst_0
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.REQUESTED_FROM_DOWNSTREAM:Lreactor/core/Scannable$Attr;
17: new reactor.core.Scannable$Attr
dup
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.TERMINATED:Lreactor/core/Scannable$Attr;
18: new reactor.core.Scannable$Attr
dup
aconst_null
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;)V
putstatic reactor.core.Scannable$Attr.TAGS:Lreactor/core/Scannable$Attr;
19: new reactor.core.Scannable$Attr$1
dup
invokespecial reactor.core.Scannable$Attr$1.<init>:()V
putstatic reactor.core.Scannable$Attr.UNAVAILABLE_SCAN:Lreactor/core/Scannable;
20: new reactor.core.Scannable$Attr$2
dup
invokespecial reactor.core.Scannable$Attr$2.<init>:()V
putstatic reactor.core.Scannable$Attr.NULL_SCAN:Lreactor/core/Scannable;
21: return
LocalVariableTable:
Start End Slot Name Signature
public T defaultValue();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.Scannable$Attr.defaultValue:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/Scannable$Attr<TT;>;
Signature: ()TT;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
boolean isConversionSafe();
descriptor: ()Z
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.Scannable$Attr.safeConverter:Ljava/util/function/Function;
ifnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/Scannable$Attr<TT;>;
T tryConvert();
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0000)
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.Scannable$Attr.safeConverter:Ljava/util/function/Function;
ifnonnull 5
3: aload 1
astore 2
start local 2 4: aload 2
areturn
end local 2 5: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.Scannable$Attr.safeConverter: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 6 0 this Lreactor/core/Scannable$Attr<TT;>;
0 6 1 o Ljava/lang/Object;
4 5 2 t TT;
Signature: (Ljava/lang/Object;)TT;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
o
protected void <init>();
descriptor: (Ljava/lang/Object;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokespecial reactor.core.Scannable$Attr.<init>:(Ljava/lang/Object;Ljava/util/function/Function;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/Scannable$Attr<TT;>;
0 2 1 defaultValue TT;
Signature: (TT;)V
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
defaultValue
protected void <init>(T, java.util.function.Function<java.lang.Object, ? extends T>);
descriptor: (Ljava/lang/Object;Ljava/util/function/Function;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield reactor.core.Scannable$Attr.defaultValue:Ljava/lang/Object;
2: aload 0
aload 2
putfield reactor.core.Scannable$Attr.safeConverter:Ljava/util/function/Function;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/Scannable$Attr<TT;>;
0 4 1 defaultValue TT;
0 4 2 safeConverter Ljava/util/function/Function<Ljava/lang/Object;+TT;>;
Signature: (TT;Ljava/util/function/Function<Ljava/lang/Object;+TT;>;)V
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
1:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
defaultValue
safeConverter
static java.util.stream.Stream<? extends reactor.core.Scannable> recurse(reactor.core.Scannable, reactor.core.Scannable$Attr<reactor.core.Scannable>);
descriptor: (Lreactor/core/Scannable;Lreactor/core/Scannable$Attr;)Ljava/util/stream/Stream;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface reactor.core.Scannable.scan:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
invokestatic reactor.core.Scannable.from:(Ljava/lang/Object;)Lreactor/core/Scannable;
astore 2
start local 2 1: aload 2
invokeinterface reactor.core.Scannable.isScanAvailable:()Z
ifne 3
2: invokestatic java.util.stream.Stream.empty:()Ljava/util/stream/Stream;
areturn
3: StackMap locals: reactor.core.Scannable
StackMap stack:
new reactor.core.Scannable$Attr$3
dup
aload 2
aload 1
invokespecial reactor.core.Scannable$Attr$3.<init>:(Lreactor/core/Scannable;Lreactor/core/Scannable$Attr;)V
4: iconst_0
5: invokestatic java.util.Spliterators.spliteratorUnknownSize:(Ljava/util/Iterator;I)Ljava/util/Spliterator;
6: iconst_0
7: invokestatic java.util.stream.StreamSupport.stream:(Ljava/util/Spliterator;Z)Ljava/util/stream/Stream;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 _s Lreactor/core/Scannable;
0 8 1 key Lreactor/core/Scannable$Attr<Lreactor/core/Scannable;>;
1 8 2 s Lreactor/core/Scannable;
Signature: (Lreactor/core/Scannable;Lreactor/core/Scannable$Attr<Lreactor/core/Scannable;>;)Ljava/util/stream/Stream<+Lreactor/core/Scannable;>;
MethodParameters:
Name Flags
_s
key
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "Scannable.java"
NestHost: reactor.core.Scannable
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
reactor.core.Scannable$Attr$1
reactor.core.Scannable$Attr$2
reactor.core.Scannable$Attr$3