final class reactor.core.publisher.ImmutableSignal<T> implements reactor.core.publisher.Signal<T>, java.io.Serializable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.ImmutableSignal
super_class: java.lang.Object
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -2004454746525418508
private final transient reactor.util.context.ContextView contextView;
descriptor: Lreactor/util/context/ContextView;
flags: (0x0092) ACC_PRIVATE, ACC_FINAL, ACC_TRANSIENT
private final reactor.core.publisher.SignalType type;
descriptor: Lreactor/core/publisher/SignalType;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.Throwable throwable;
descriptor: Ljava/lang/Throwable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final T value;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: TT;
private final transient org.reactivestreams.Subscription subscription;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0092) ACC_PRIVATE, ACC_FINAL, ACC_TRANSIENT
private static final reactor.core.publisher.Signal<?> ON_COMPLETE;
descriptor: Lreactor/core/publisher/Signal;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lreactor/core/publisher/Signal<*>;
private static volatile int[] $SWITCH_TABLE$reactor$core$publisher$SignalType;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=0, args_size=0
0: new reactor.core.publisher.ImmutableSignal
dup
invokestatic reactor.util.context.Context.empty:()Lreactor/util/context/Context;
getstatic reactor.core.publisher.SignalType.ON_COMPLETE:Lreactor/core/publisher/SignalType;
aconst_null
aconst_null
aconst_null
invokespecial reactor.core.publisher.ImmutableSignal.<init>:(Lreactor/util/context/ContextView;Lreactor/core/publisher/SignalType;Ljava/lang/Object;Ljava/lang/Throwable;Lorg/reactivestreams/Subscription;)V
1: putstatic reactor.core.publisher.ImmutableSignal.ON_COMPLETE:Lreactor/core/publisher/Signal;
2: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(reactor.util.context.ContextView, reactor.core.publisher.SignalType, T, java.lang.Throwable, org.reactivestreams.Subscription);
descriptor: (Lreactor/util/context/ContextView;Lreactor/core/publisher/SignalType;Ljava/lang/Object;Ljava/lang/Throwable;Lorg/reactivestreams/Subscription;)V
flags: (0x0000)
Code:
stack=2, 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
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield reactor.core.publisher.ImmutableSignal.contextView:Lreactor/util/context/ContextView;
2: aload 0
aload 3
putfield reactor.core.publisher.ImmutableSignal.value:Ljava/lang/Object;
3: aload 0
aload 5
putfield reactor.core.publisher.ImmutableSignal.subscription:Lorg/reactivestreams/Subscription;
4: aload 0
aload 4
putfield reactor.core.publisher.ImmutableSignal.throwable:Ljava/lang/Throwable;
5: aload 0
aload 2
putfield reactor.core.publisher.ImmutableSignal.type:Lreactor/core/publisher/SignalType;
6: 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 7 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
0 7 1 contextView Lreactor/util/context/ContextView;
0 7 2 type Lreactor/core/publisher/SignalType;
0 7 3 value TT;
0 7 4 e Ljava/lang/Throwable;
0 7 5 subscription Lorg/reactivestreams/Subscription;
Signature: (Lreactor/util/context/ContextView;Lreactor/core/publisher/SignalType;TT;Ljava/lang/Throwable;Lorg/reactivestreams/Subscription;)V
RuntimeVisibleParameterAnnotations:
0:
1:
2:
reactor.util.annotation.Nullable()
3:
reactor.util.annotation.Nullable()
4:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
contextView
type
value
e
subscription
public java.lang.Throwable getThrowable();
descriptor: ()Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ImmutableSignal.throwable:Ljava/lang/Throwable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
public org.reactivestreams.Subscription getSubscription();
descriptor: ()Lorg/reactivestreams/Subscription;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ImmutableSignal.subscription:Lorg/reactivestreams/Subscription;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
public T get();
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.publisher.ImmutableSignal.value:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
Signature: ()TT;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
public reactor.core.publisher.SignalType getType();
descriptor: ()Lreactor/core/publisher/SignalType;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ImmutableSignal.type:Lreactor/core/publisher/SignalType;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
public reactor.util.context.ContextView getContextView();
descriptor: ()Lreactor/util/context/ContextView;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ImmutableSignal.contextView:Lreactor/util/context/ContextView;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
public boolean equals(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
if_acmpne 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 1
ifnull 3
aload 1
instanceof reactor.core.publisher.Signal
ifne 4
3: StackMap locals:
StackMap stack:
iconst_0
ireturn
4: StackMap locals:
StackMap stack:
aload 1
checkcast reactor.core.publisher.Signal
astore 2
start local 2 5: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getType:()Lreactor/core/publisher/SignalType;
aload 2
invokeinterface reactor.core.publisher.Signal.getType:()Lreactor/core/publisher/SignalType;
if_acmpeq 7
6: iconst_0
ireturn
7: StackMap locals: reactor.core.publisher.Signal
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnComplete:()Z
ifeq 9
8: iconst_1
ireturn
9: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnSubscribe:()Z
ifeq 11
10: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getSubscription:()Lorg/reactivestreams/Subscription;
aload 2
invokeinterface reactor.core.publisher.Signal.getSubscription:()Lorg/reactivestreams/Subscription;
invokestatic java.util.Objects.equals:(Ljava/lang/Object;Ljava/lang/Object;)Z
ireturn
11: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnError:()Z
ifeq 13
12: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getThrowable:()Ljava/lang/Throwable;
aload 2
invokeinterface reactor.core.publisher.Signal.getThrowable:()Ljava/lang/Throwable;
invokestatic java.util.Objects.equals:(Ljava/lang/Object;Ljava/lang/Object;)Z
ireturn
13: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnNext:()Z
ifeq 15
14: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.get:()Ljava/lang/Object;
aload 2
invokeinterface reactor.core.publisher.Signal.get:()Ljava/lang/Object;
invokestatic java.util.Objects.equals:(Ljava/lang/Object;Ljava/lang/Object;)Z
ireturn
15: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
0 16 1 o Ljava/lang/Object;
5 16 2 signal Lreactor/core/publisher/Signal<*>;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
o
public int hashCode();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getType:()Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.hashCode:()I
istore 1
start local 1 1: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnError:()Z
ifeq 5
2: bipush 31
iload 1
imul
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getThrowable:()Ljava/lang/Throwable;
ifnull 3
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getThrowable:()Ljava/lang/Throwable;
invokevirtual java.lang.Object.hashCode:()I
goto 4
3: StackMap locals: reactor.core.publisher.ImmutableSignal int
StackMap stack: int
iconst_0
4: StackMap locals: reactor.core.publisher.ImmutableSignal int
StackMap stack: int int
iadd
ireturn
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnNext:()Z
ifeq 9
6: bipush 31
iload 1
imul
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.get:()Ljava/lang/Object;
ifnull 7
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.get:()Ljava/lang/Object;
invokevirtual java.lang.Object.hashCode:()I
goto 8
StackMap locals:
StackMap stack: int
7: iconst_0
StackMap locals: reactor.core.publisher.ImmutableSignal int
StackMap stack: int int
8: iadd
ireturn
9: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.isOnSubscribe:()Z
ifeq 14
10: bipush 31
iload 1
imul
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getSubscription:()Lorg/reactivestreams/Subscription;
ifnull 12
11: aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getSubscription:()Lorg/reactivestreams/Subscription;
invokevirtual java.lang.Object.hashCode:()I
goto 13
StackMap locals:
StackMap stack: int
12: iconst_0
13: StackMap locals: reactor.core.publisher.ImmutableSignal int
StackMap stack: int int
iadd
ireturn
14: StackMap locals:
StackMap stack:
iload 1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
1 15 1 result I
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: invokestatic reactor.core.publisher.ImmutableSignal.$SWITCH_TABLE$reactor$core$publisher$SignalType:()[I
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getType:()Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iaload
tableswitch { // 4 - 7
4: 1
5: 2
6: 3
7: 4
default: 5
}
1: StackMap locals:
StackMap stack:
ldc "onSubscribe(%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getSubscription:()Lorg/reactivestreams/Subscription;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
2: StackMap locals:
StackMap stack:
ldc "onNext(%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.get:()Ljava/lang/Object;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
3: StackMap locals:
StackMap stack:
ldc "onError(%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getThrowable:()Ljava/lang/Throwable;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
4: StackMap locals:
StackMap stack:
ldc "onComplete()"
areturn
5: StackMap locals:
StackMap stack:
ldc "Signal type=%s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual reactor.core.publisher.ImmutableSignal.getType:()Lreactor/core/publisher/SignalType;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/ImmutableSignal<TT;>;
static <U> reactor.core.publisher.Signal<U> onComplete();
descriptor: ()Lreactor/core/publisher/Signal;
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic reactor.core.publisher.ImmutableSignal.ON_COMPLETE:Lreactor/core/publisher/Signal;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <U:Ljava/lang/Object;>()Lreactor/core/publisher/Signal<TU;>;
public void accept(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast org.reactivestreams.Subscriber
invokeinterface reactor.core.publisher.Signal.accept:(Lorg/reactivestreams/Subscriber;)V
return
LocalVariableTable:
Start End Slot Name Signature
static int[] $SWITCH_TABLE$reactor$core$publisher$SignalType();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic reactor.core.publisher.ImmutableSignal.$SWITCH_TABLE$reactor$core$publisher$SignalType:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic reactor.core.publisher.SignalType.values:()[Lreactor/core/publisher/SignalType;
arraylength
newarray 10
astore 0
2: aload 0
getstatic reactor.core.publisher.SignalType.AFTER_TERMINATE:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
bipush 8
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic reactor.core.publisher.SignalType.CANCEL:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iconst_3
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic reactor.core.publisher.SignalType.CURRENT_CONTEXT:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
bipush 9
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic reactor.core.publisher.SignalType.ON_COMPLETE:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
bipush 7
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
getstatic reactor.core.publisher.SignalType.ON_CONTEXT:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
bipush 10
iastore
15: goto 17
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
16: pop
StackMap locals:
StackMap stack:
17: aload 0
getstatic reactor.core.publisher.SignalType.ON_ERROR:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
bipush 6
iastore
18: goto 20
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
19: pop
StackMap locals:
StackMap stack:
20: aload 0
getstatic reactor.core.publisher.SignalType.ON_NEXT:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iconst_5
iastore
21: goto 23
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
22: pop
StackMap locals:
StackMap stack:
23: aload 0
getstatic reactor.core.publisher.SignalType.ON_SUBSCRIBE:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iconst_4
iastore
24: goto 26
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
25: pop
StackMap locals:
StackMap stack:
26: aload 0
getstatic reactor.core.publisher.SignalType.REQUEST:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iconst_2
iastore
27: goto 29
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
28: pop
StackMap locals:
StackMap stack:
29: aload 0
getstatic reactor.core.publisher.SignalType.SUBSCRIBE:Lreactor/core/publisher/SignalType;
invokevirtual reactor.core.publisher.SignalType.ordinal:()I
iconst_1
iastore
30: goto 32
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
31: pop
StackMap locals:
StackMap stack:
32: aload 0
dup
putstatic reactor.core.publisher.ImmutableSignal.$SWITCH_TABLE$reactor$core$publisher$SignalType:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
11 12 13 Class java.lang.NoSuchFieldError
14 15 16 Class java.lang.NoSuchFieldError
17 18 19 Class java.lang.NoSuchFieldError
20 21 22 Class java.lang.NoSuchFieldError
23 24 25 Class java.lang.NoSuchFieldError
26 27 28 Class java.lang.NoSuchFieldError
29 30 31 Class java.lang.NoSuchFieldError
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/publisher/Signal<TT;>;Ljava/io/Serializable;
SourceFile: "ImmutableSignal.java"