final class reactor.core.publisher.FluxCreate$BufferAsyncSink<T> extends reactor.core.publisher.FluxCreate$BaseSink<T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxCreate$BufferAsyncSink
super_class: reactor.core.publisher.FluxCreate$BaseSink
{
final java.util.Queue<T> queue;
descriptor: Ljava/util/Queue;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/Queue<TT;>;
java.lang.Throwable error;
descriptor: Ljava/lang/Throwable;
flags: (0x0000)
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile int wip;
descriptor: I
flags: (0x0040) ACC_VOLATILE
static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<reactor.core.publisher.FluxCreate$BufferAsyncSink> WIP;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lreactor/core/publisher/FluxCreate$BufferAsyncSink;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc Lreactor/core/publisher/FluxCreate$BufferAsyncSink;
ldc "wip"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
1: putstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
2: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(reactor.core.CoreSubscriber<? super T>, );
descriptor: (Lreactor/core/CoreSubscriber;I)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokespecial reactor.core.publisher.FluxCreate$BaseSink.<init>:(Lreactor/core/CoreSubscriber;)V
1: aload 0
iload 2
invokestatic reactor.util.concurrent.Queues.unbounded:(I)Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Queue
putfield reactor.core.publisher.FluxCreate$BufferAsyncSink.queue:Ljava/util/Queue;
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
0 3 1 actual Lreactor/core/CoreSubscriber<-TT;>;
0 3 2 capacityHint I
Signature: (Lreactor/core/CoreSubscriber<-TT;>;I)V
MethodParameters:
Name Flags
actual
capacityHint
public reactor.core.publisher.FluxSink<T> next(T);
descriptor: (Ljava/lang/Object;)Lreactor/core/publisher/FluxSink;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.queue:Ljava/util/Queue;
aload 1
invokeinterface java.util.Queue.offer:(Ljava/lang/Object;)Z
pop
1: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.drain:()V
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
0 3 1 t TT;
Signature: (TT;)Lreactor/core/publisher/FluxSink<TT;>;
MethodParameters:
Name Flags
t
public void error(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield reactor.core.publisher.FluxCreate$BufferAsyncSink.error:Ljava/lang/Throwable;
1: aload 0
iconst_1
putfield reactor.core.publisher.FluxCreate$BufferAsyncSink.done:Z
2: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.drain:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
0 4 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void complete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield reactor.core.publisher.FluxCreate$BufferAsyncSink.done:Z
1: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
void onRequestedFromDownstream();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.drain:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
void onCancel();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.drain:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=4, locals=11, args_size=1
start local 0 0: getstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement:(Ljava/lang/Object;)I
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.actual:Lreactor/core/CoreSubscriber;
astore 1
start local 1 3: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.queue:Ljava/util/Queue;
astore 2
start local 2 4: StackMap locals: org.reactivestreams.Subscriber java.util.Queue
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.requested:J
lstore 3
start local 3 5: lconst_0
lstore 5
start local 5 6: goto 28
7: StackMap locals: long long
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.isCancelled:()Z
ifeq 12
8: aload 2
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.ctx:Lreactor/util/context/Context;
aconst_null
invokestatic reactor.core.publisher.Operators.onDiscardQueueWithClear:(Ljava/util/Queue;Lreactor/util/context/Context;Ljava/util/function/Function;)V
9: getstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet:(Ljava/lang/Object;)I
ifeq 11
10: goto 28
11: StackMap locals:
StackMap stack:
return
12: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.done:Z
istore 7
start local 7 13: aload 2
invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
astore 8
start local 8 14: aload 8
ifnonnull 15
iconst_1
goto 16
StackMap locals: int java.lang.Object
StackMap stack:
15: iconst_0
StackMap locals:
StackMap stack: int
16: istore 9
start local 9 17: iload 7
ifeq 24
iload 9
ifeq 24
18: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.error:Ljava/lang/Throwable;
astore 10
start local 10 19: aload 10
ifnull 22
20: aload 0
aload 10
invokespecial reactor.core.publisher.FluxCreate$BaseSink.error:(Ljava/lang/Throwable;)V
21: goto 23
22: StackMap locals: int java.lang.Throwable
StackMap stack:
aload 0
invokespecial reactor.core.publisher.FluxCreate$BaseSink.complete:()V
23: StackMap locals:
StackMap stack:
return
end local 10 24: StackMap locals:
StackMap stack:
iload 9
ifeq 26
25: goto 29
26: StackMap locals:
StackMap stack:
aload 1
aload 8
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
27: lload 5
lconst_1
ladd
lstore 5
end local 9 end local 8 end local 7 28: StackMap locals:
StackMap stack:
lload 5
lload 3
lcmp
ifne 7
29: StackMap locals:
StackMap stack:
lload 5
lload 3
lcmp
ifne 44
30: aload 0
invokevirtual reactor.core.publisher.FluxCreate$BufferAsyncSink.isCancelled:()Z
ifeq 35
31: aload 2
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.ctx:Lreactor/util/context/Context;
aconst_null
invokestatic reactor.core.publisher.Operators.onDiscardQueueWithClear:(Ljava/util/Queue;Lreactor/util/context/Context;Ljava/util/function/Function;)V
32: getstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet:(Ljava/lang/Object;)I
ifeq 34
33: goto 4
34: StackMap locals:
StackMap stack:
return
35: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.done:Z
istore 7
start local 7 36: aload 2
invokeinterface java.util.Queue.isEmpty:()Z
istore 8
start local 8 37: iload 7
ifeq 44
iload 8
ifeq 44
38: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.error:Ljava/lang/Throwable;
astore 9
start local 9 39: aload 9
ifnull 42
40: aload 0
aload 9
invokespecial reactor.core.publisher.FluxCreate$BaseSink.error:(Ljava/lang/Throwable;)V
41: goto 43
42: StackMap locals: int int java.lang.Throwable
StackMap stack:
aload 0
invokespecial reactor.core.publisher.FluxCreate$BaseSink.complete:()V
43: StackMap locals:
StackMap stack:
return
end local 9 end local 8 end local 7 44: StackMap locals:
StackMap stack:
lload 5
lconst_0
lcmp
ifeq 46
45: getstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.REQUESTED:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
aload 0
lload 5
invokestatic reactor.core.publisher.Operators.produced:(Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;Ljava/lang/Object;J)J
pop2
46: StackMap locals:
StackMap stack:
getstatic reactor.core.publisher.FluxCreate$BufferAsyncSink.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet:(Ljava/lang/Object;)I
ifne 4
end local 5 end local 3 47: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 48 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
3 48 1 a Lorg/reactivestreams/Subscriber<-TT;>;
4 48 2 q Ljava/util/Queue<TT;>;
5 47 3 r J
6 47 5 e J
13 28 7 d Z
14 28 8 o TT;
17 28 9 empty Z
19 24 10 ex Ljava/lang/Throwable;
36 44 7 d Z
37 44 8 empty Z
39 44 9 ex Ljava/lang/Throwable;
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.BUFFERED:Lreactor/core/Scannable$Attr;
if_acmpne 2
1: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.queue:Ljava/util/Queue;
invokeinterface java.util.Queue.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
2: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.TERMINATED:Lreactor/core/Scannable$Attr;
if_acmpne 4
3: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.done:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
4: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.ERROR:Lreactor/core/Scannable$Attr;
if_acmpne 6
5: aload 0
getfield reactor.core.publisher.FluxCreate$BufferAsyncSink.error:Ljava/lang/Throwable;
areturn
6: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial reactor.core.publisher.FluxCreate$BaseSink.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
0 7 1 key Lreactor/core/Scannable$Attr;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
key
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "FluxSink("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
getstatic reactor.core.publisher.FluxSink$OverflowStrategy.BUFFER:Lreactor/core/publisher/FluxSink$OverflowStrategy;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ")"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxCreate$BufferAsyncSink<TT;>;
}
Signature: <T:Ljava/lang/Object;>Lreactor/core/publisher/FluxCreate$BaseSink<TT;>;
SourceFile: "FluxCreate.java"
NestHost: reactor.core.publisher.FluxCreate
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
abstract BaseSink = reactor.core.publisher.FluxCreate$BaseSink of reactor.core.publisher.FluxCreate
final BufferAsyncSink = reactor.core.publisher.FluxCreate$BufferAsyncSink of reactor.core.publisher.FluxCreate
public final OverflowStrategy = reactor.core.publisher.FluxSink$OverflowStrategy of reactor.core.publisher.FluxSink