final class reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator<T> implements org.reactivestreams.Subscription, reactor.core.Scannable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator
super_class: java.lang.Object
{
final reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber<T>[] subscribers;
descriptor: [Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
flags: (0x0010) ACC_FINAL
Signature: [Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber<TT;>;
volatile boolean cancelled;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile int winner;
descriptor: I
flags: (0x0040) ACC_VOLATILE
static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator> WINNER;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator;
ldc "winner"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
1: putstatic reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.WINNER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
2: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(int);
descriptor: (I)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iload 1
anewarray reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber
putfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
2: aload 0
ldc -2147483648
putfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.winner:I
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
0 4 1 n I
MethodParameters:
Name Flags
n
public java.util.stream.Stream<? extends reactor.core.Scannable> inners();
descriptor: ()Ljava/util/stream/Stream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
invokestatic java.util.stream.Stream.of:([Ljava/lang/Object;)Ljava/util/stream/Stream;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
Signature: ()Ljava/util/stream/Stream<+Lreactor/core/Scannable;>;
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.CANCELLED:Lreactor/core/Scannable$Attr;
if_acmpne 1
aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.cancelled:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
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/FluxFirstWithSignal$RaceCoordinator<TT;>;
0 2 1 key Lreactor/core/Scannable$Attr;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
key
void subscribe(org.reactivestreams.Publisher<? extends T>[], int, reactor.core.CoreSubscriber<? super T>);
descriptor: ([Lorg/reactivestreams/Publisher;ILreactor/core/CoreSubscriber;)V
flags: (0x0000)
Code:
stack=7, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
astore 4
start local 4 1: iconst_0
istore 5
start local 5 2: goto 5
3: StackMap locals: reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber[] int
StackMap stack:
aload 4
iload 5
new reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber
dup
aload 3
aload 0
iload 5
invokespecial reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.<init>:(Lreactor/core/CoreSubscriber;Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator;I)V
aastore
4: iinc 5 1
StackMap locals:
StackMap stack:
5: iload 5
iload 2
if_icmplt 3
end local 5 6: aload 3
aload 0
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
7: iconst_0
istore 5
start local 5 8: goto 18
9: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.cancelled:Z
ifne 10
aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.winner:I
ldc -2147483648
if_icmpeq 11
10: StackMap locals:
StackMap stack:
return
11: StackMap locals:
StackMap stack:
aload 1
iload 5
aaload
astore 6
start local 6 12: aload 6
ifnonnull 16
13: getstatic reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.WINNER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
ldc -2147483648
iconst_m1
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
ifeq 15
14: aload 3
new java.lang.NullPointerException
dup
new java.lang.StringBuilder
dup
ldc "The "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 5
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " th Publisher source is null"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
15: StackMap locals: org.reactivestreams.Publisher
StackMap stack:
return
16: StackMap locals:
StackMap stack:
aload 6
aload 4
iload 5
aaload
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
end local 6 17: iinc 5 1
StackMap locals:
StackMap stack:
18: iload 5
iload 2
if_icmplt 9
end local 5 19: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
0 20 1 sources [Lorg/reactivestreams/Publisher;
0 20 2 n I
0 20 3 actual Lreactor/core/CoreSubscriber<-TT;>;
1 20 4 a [Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
2 6 5 i I
8 19 5 i I
12 17 6 p Lorg/reactivestreams/Publisher<+TT;>;
Signature: ([Lorg/reactivestreams/Publisher<+TT;>;ILreactor/core/CoreSubscriber<-TT;>;)V
MethodParameters:
Name Flags
sources
n
actual
public void request(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: lload 1
invokestatic reactor.core.publisher.Operators.validate:(J)Z
ifeq 10
1: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.winner:I
istore 3
start local 3 2: iload 3
iflt 5
3: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
iload 3
aaload
lload 1
invokevirtual reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.request:(J)V
4: goto 10
5: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 9
StackMap locals: reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator long int top int int reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber[]
StackMap stack:
6: aload 7
iload 5
aaload
astore 4
start local 4 7: aload 4
lload 1
invokevirtual reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.request:(J)V
end local 4 8: iinc 5 1
StackMap locals:
StackMap stack:
9: iload 5
iload 6
if_icmplt 6
end local 3 10: StackMap locals: reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator long
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
0 11 1 n J
2 10 3 w I
7 8 4 s Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber<TT;>;
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=6, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.cancelled:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.cancelled:Z
3: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.winner:I
istore 1
start local 1 4: iload 1
iflt 7
5: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
iload 1
aaload
invokevirtual reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.cancel:()V
6: goto 12
7: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 11
StackMap locals: reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator int top int int reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber[]
StackMap stack:
8: aload 5
iload 3
aaload
astore 2
start local 2 9: aload 2
invokevirtual reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.cancel:()V
end local 2 10: iinc 3 1
StackMap locals:
StackMap stack:
11: iload 3
iload 4
if_icmplt 8
12: StackMap locals: reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator int
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
4 13 1 w I
9 10 2 s Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber<TT;>;
boolean tryWin(int);
descriptor: (I)Z
flags: (0x0000)
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.winner:I
ldc -2147483648
if_icmpne 11
1: getstatic reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.WINNER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
ldc -2147483648
iload 1
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet:(Ljava/lang/Object;II)Z
ifeq 11
2: aload 0
getfield reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
astore 2
start local 2 3: aload 2
arraylength
istore 3
start local 3 4: iconst_0
istore 4
start local 4 5: goto 9
6: StackMap locals: reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber[] int int
StackMap stack:
iload 4
iload 1
if_icmpeq 8
7: aload 2
iload 4
aaload
invokevirtual reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber.cancel:()V
8: StackMap locals:
StackMap stack:
iinc 4 1
StackMap locals:
StackMap stack:
9: iload 4
iload 3
if_icmplt 6
end local 4 10: iconst_1
ireturn
end local 3 end local 2 11: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lreactor/core/publisher/FluxFirstWithSignal$RaceCoordinator<TT;>;
0 12 1 index I
3 11 2 a [Lreactor/core/publisher/FluxFirstWithSignal$FirstEmittingSubscriber;
4 11 3 n I
5 10 4 i I
MethodParameters:
Name Flags
index
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/reactivestreams/Subscription;Lreactor/core/Scannable;
SourceFile: "FluxFirstWithSignal.java"
NestHost: reactor.core.publisher.FluxFirstWithSignal
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
final FirstEmittingSubscriber = reactor.core.publisher.FluxFirstWithSignal$FirstEmittingSubscriber of reactor.core.publisher.FluxFirstWithSignal
final RaceCoordinator = reactor.core.publisher.FluxFirstWithSignal$RaceCoordinator of reactor.core.publisher.FluxFirstWithSignal