final class reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator<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.FluxFirstWithValue$RaceValuesCoordinator
super_class: java.lang.Object
{
final reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber<T>[] subscribers;
descriptor: [Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
flags: (0x0010) ACC_FINAL
Signature: [Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber<TT;>;
final java.lang.Throwable[] errorsOrCompleteEmpty;
descriptor: [Ljava/lang/Throwable;
flags: (0x0010) ACC_FINAL
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.FluxFirstWithValue$RaceValuesCoordinator> WINNER;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator;>;
volatile int nbErrorsOrCompletedEmpty;
descriptor: I
flags: (0x0040) ACC_VOLATILE
static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator> ERRORS_OR_COMPLETED_EMPTY;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator;
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.FluxFirstWithValue$RaceValuesCoordinator.WINNER:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
2: ldc Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator;
ldc "nbErrorsOrCompletedEmpty"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
3: putstatic reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.ERRORS_OR_COMPLETED_EMPTY:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
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.FluxFirstWithValue$FirstValuesEmittingSubscriber
putfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
2: aload 0
iload 1
anewarray java.lang.Throwable
putfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.errorsOrCompleteEmpty:[Ljava/lang/Throwable;
3: aload 0
ldc -2147483648
putfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.winner:I
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
0 5 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.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
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/FluxFirstWithValue$RaceValuesCoordinator<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.FluxFirstWithValue$RaceValuesCoordinator.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/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
0 2 1 key Lreactor/core/Scannable$Attr;
MethodParameters:
Name Flags
key
void subscribe(org.reactivestreams.Publisher<? extends T>[], reactor.core.CoreSubscriber<? super T>);
descriptor: ([Lorg/reactivestreams/Publisher;Lreactor/core/CoreSubscriber;)V
flags: (0x0000)
Code:
stack=7, locals=4, args_size=3
start local 0 start local 1 start local 2 0: iconst_0
istore 3
start local 3 1: goto 4
2: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
iload 3
new reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber
dup
aload 2
aload 0
iload 3
invokespecial reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.<init>:(Lreactor/core/CoreSubscriber;Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator;I)V
aastore
3: iinc 3 1
StackMap locals:
StackMap stack:
4: iload 3
aload 1
arraylength
if_icmplt 2
end local 3 5: aload 2
aload 0
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
6: iconst_0
istore 3
start local 3 7: goto 15
8: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.cancelled:Z
ifne 9
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.winner:I
ldc -2147483648
if_icmpeq 10
9: StackMap locals:
StackMap stack:
return
10: StackMap locals:
StackMap stack:
aload 1
iload 3
aaload
ifnonnull 13
11: aload 2
new java.lang.NullPointerException
dup
new java.lang.StringBuilder
dup
ldc "The "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 3
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
12: return
13: StackMap locals:
StackMap stack:
aload 1
iload 3
aaload
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
iload 3
aaload
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
14: iinc 3 1
StackMap locals:
StackMap stack:
15: iload 3
aload 1
arraylength
if_icmplt 8
end local 3 16: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
0 17 1 sources [Lorg/reactivestreams/Publisher;
0 17 2 actual Lreactor/core/CoreSubscriber<-TT;>;
1 5 3 i I
7 16 3 i I
Signature: ([Lorg/reactivestreams/Publisher<+TT;>;Lreactor/core/CoreSubscriber<-TT;>;)V
MethodParameters:
Name Flags
sources
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.FluxFirstWithValue$RaceValuesCoordinator.winner:I
istore 3
start local 3 2: iload 3
iflt 5
3: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
iload 3
aaload
lload 1
invokevirtual reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.request:(J)V
4: goto 10
5: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 9
StackMap locals: reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator long int top int int reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber[]
StackMap stack:
6: aload 7
iload 5
aaload
astore 4
start local 4 7: aload 4
lload 1
invokevirtual reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.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.FluxFirstWithValue$RaceValuesCoordinator long
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
0 11 1 n J
2 10 3 w I
7 8 4 s Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber<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.FluxFirstWithValue$RaceValuesCoordinator.cancelled:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.cancelled:Z
3: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.winner:I
istore 1
start local 1 4: iload 1
iflt 7
5: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
iload 1
aaload
invokevirtual reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.cancel:()V
6: goto 12
7: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 11
StackMap locals: reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator int top int int reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber[]
StackMap stack:
8: aload 5
iload 3
aaload
astore 2
start local 2 9: aload 2
invokevirtual reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.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.FluxFirstWithValue$RaceValuesCoordinator int
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
4 13 1 w I
9 10 2 s Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber<TT;>;
boolean tryWin(int);
descriptor: (I)Z
flags: (0x0000)
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.winner:I
ldc -2147483648
if_icmpne 10
1: getstatic reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.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 10
2: iconst_0
istore 2
start local 2 3: goto 8
4: StackMap locals: int
StackMap stack:
iload 2
iload 1
if_icmpeq 7
5: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
iload 2
aaload
invokevirtual reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber.cancel:()V
6: aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.errorsOrCompleteEmpty:[Ljava/lang/Throwable;
iload 2
aconst_null
aastore
7: StackMap locals:
StackMap stack:
iinc 2 1
StackMap locals:
StackMap stack:
8: iload 2
aload 0
getfield reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator.subscribers:[Lreactor/core/publisher/FluxFirstWithValue$FirstValuesEmittingSubscriber;
arraylength
if_icmplt 4
end local 2 9: iconst_1
ireturn
10: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/FluxFirstWithValue$RaceValuesCoordinator<TT;>;
0 11 1 index I
3 9 2 i I
MethodParameters:
Name Flags
index
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/reactivestreams/Subscription;Lreactor/core/Scannable;
SourceFile: "FluxFirstWithValue.java"
NestHost: reactor.core.publisher.FluxFirstWithValue
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
final FirstValuesEmittingSubscriber = reactor.core.publisher.FluxFirstWithValue$FirstValuesEmittingSubscriber of reactor.core.publisher.FluxFirstWithValue
final RaceValuesCoordinator = reactor.core.publisher.FluxFirstWithValue$RaceValuesCoordinator of reactor.core.publisher.FluxFirstWithValue