final class reactor.core.publisher.FluxConcatMap$ConcatMapDelayed<T, R> implements reactor.core.publisher.FluxConcatMap$FluxConcatMapSupport<T, R>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed
super_class: java.lang.Object
{
final reactor.core.CoreSubscriber<? super R> actual;
descriptor: Lreactor/core/CoreSubscriber;
flags: (0x0010) ACC_FINAL
Signature: Lreactor/core/CoreSubscriber<-TR;>;
final reactor.core.publisher.FluxConcatMap$ConcatMapInner<R> inner;
descriptor: Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
flags: (0x0010) ACC_FINAL
Signature: Lreactor/core/publisher/FluxConcatMap$ConcatMapInner<TR;>;
final java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper;
descriptor: Ljava/util/function/Function;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
final java.util.function.Supplier<? extends java.util.Queue<T>> queueSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Supplier<+Ljava/util/Queue<TT;>;>;
final int prefetch;
descriptor: I
flags: (0x0010) ACC_FINAL
final int limit;
descriptor: I
flags: (0x0010) ACC_FINAL
final boolean veryEnd;
descriptor: Z
flags: (0x0010) ACC_FINAL
org.reactivestreams.Subscription s;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
int consumed;
descriptor: I
flags: (0x0000)
volatile java.util.Queue<T> queue;
descriptor: Ljava/util/Queue;
flags: (0x0040) ACC_VOLATILE
Signature: Ljava/util/Queue<TT;>;
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile boolean cancelled;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile java.lang.Throwable error;
descriptor: Ljava/lang/Throwable;
flags: (0x0040) ACC_VOLATILE
static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<reactor.core.publisher.FluxConcatMap$ConcatMapDelayed, java.lang.Throwable> ERROR;
descriptor: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed;Ljava/lang/Throwable;>;
volatile boolean active;
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.FluxConcatMap$ConcatMapDelayed> WIP;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed;>;
int sourceMode;
descriptor: I
flags: (0x0000)
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed;
1: ldc Ljava/lang/Throwable;
2: ldc "error"
3: invokestatic java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
4: putstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
5: ldc Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed;
ldc "wip"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
6: putstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
7: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(reactor.core.CoreSubscriber<? super R>, java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, java.util.function.Supplier<? extends java.util.Queue<T>>, int, );
descriptor: (Lreactor/core/CoreSubscriber;Ljava/util/function/Function;Ljava/util/function/Supplier;IZ)V
flags: (0x0000)
Code:
stack=4, 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.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
2: aload 0
aload 2
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.mapper:Ljava/util/function/Function;
3: aload 0
aload 3
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queueSupplier:Ljava/util/function/Supplier;
4: aload 0
iload 4
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.prefetch:I
5: aload 0
iload 4
invokestatic reactor.core.publisher.Operators.unboundedOrLimit:(I)I
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.limit:I
6: aload 0
iload 5
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.veryEnd:Z
7: aload 0
new reactor.core.publisher.FluxConcatMap$ConcatMapInner
dup
aload 0
invokespecial reactor.core.publisher.FluxConcatMap$ConcatMapInner.<init>:(Lreactor/core/publisher/FluxConcatMap$FluxConcatMapSupport;)V
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
8: 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 9 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 9 1 actual Lreactor/core/CoreSubscriber<-TR;>;
0 9 2 mapper Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
0 9 3 queueSupplier Ljava/util/function/Supplier<+Ljava/util/Queue<TT;>;>;
0 9 4 prefetch I
0 9 5 veryEnd Z
Signature: (Lreactor/core/CoreSubscriber<-TR;>;Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;Ljava/util/function/Supplier<+Ljava/util/Queue<TT;>;>;IZ)V
MethodParameters:
Name Flags
actual
mapper
queueSupplier
prefetch
veryEnd
public reactor.core.CoreSubscriber<? super R> actual();
descriptor: ()Lreactor/core/CoreSubscriber;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
Signature: ()Lreactor/core/CoreSubscriber<-TR;>;
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.PARENT:Lreactor/core/Scannable$Attr;
if_acmpne 1
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
areturn
1: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.TERMINATED:Lreactor/core/Scannable$Attr;
if_acmpne 2
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.done:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
2: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.CANCELLED:Lreactor/core/Scannable$Attr;
if_acmpne 3
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.cancelled:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
3: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.PREFETCH:Lreactor/core/Scannable$Attr;
if_acmpne 4
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.prefetch:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
4: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.BUFFERED:Lreactor/core/Scannable$Attr;
if_acmpne 7
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
ifnull 5
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
invokeinterface java.util.Queue.size:()I
goto 6
StackMap locals:
StackMap stack:
5: iconst_0
StackMap locals:
StackMap stack: int
6: invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
7: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.ERROR:Lreactor/core/Scannable$Attr;
if_acmpne 8
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.error:Ljava/lang/Throwable;
areturn
8: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.DELAY_ERROR:Lreactor/core/Scannable$Attr;
if_acmpne 9
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
9: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.RUN_STYLE:Lreactor/core/Scannable$Attr;
if_acmpne 10
getstatic reactor.core.Scannable$Attr$RunStyle.SYNC:Lreactor/core/Scannable$Attr$RunStyle;
areturn
10: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial reactor.core.publisher.FluxConcatMap$FluxConcatMapSupport.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 11 1 key Lreactor/core/Scannable$Attr;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
key
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
aload 1
invokestatic reactor.core.publisher.Operators.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 22
1: aload 0
aload 1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
2: aload 1
instanceof reactor.core.Fuseable$QueueSubscription
ifeq 19
3: aload 1
checkcast reactor.core.Fuseable$QueueSubscription
4: astore 2
start local 2 5: aload 2
bipush 7
invokeinterface reactor.core.Fuseable$QueueSubscription.requestFusion:(I)I
istore 3
start local 3 6: iload 3
iconst_1
if_icmpne 13
7: aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.sourceMode:I
8: aload 0
aload 2
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
9: aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.done:Z
10: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 0
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
11: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
12: return
13: StackMap locals: reactor.core.Fuseable$QueueSubscription int
StackMap stack:
iload 3
iconst_2
if_icmpne 17
14: aload 0
iconst_2
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.sourceMode:I
15: aload 0
aload 2
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
16: goto 20
17: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queueSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Queue
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
end local 3 end local 2 18: goto 20
19: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queueSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast java.util.Queue
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
20: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 0
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
21: aload 1
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.prefetch:I
invokestatic reactor.core.publisher.Operators.unboundedOrPrefetch:(I)J
invokeinterface org.reactivestreams.Subscription.request:(J)V
22: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 23 1 s Lorg/reactivestreams/Subscription;
5 18 2 f Lreactor/core/Fuseable$QueueSubscription<TT;>;
6 18 3 m I
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.sourceMode:I
iconst_2
if_icmpne 3
1: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
2: goto 11
3: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
aload 1
invokeinterface java.util.Queue.offer:(Ljava/lang/Object;)Z
ifne 10
4: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
astore 2
start local 2 5: aload 0
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
ldc "Queue is full: Reactive Streams source doesn't respect backpressure"
invokestatic reactor.core.Exceptions.failWithOverflow:(Ljava/lang/String;)Ljava/lang/IllegalStateException;
aload 1
6: aload 2
7: invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Ljava/lang/Object;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.onError:(Ljava/lang/Throwable;)V
8: aload 1
aload 2
invokestatic reactor.core.publisher.Operators.onDiscard:(Ljava/lang/Object;Lreactor/util/context/Context;)V
end local 2 9: goto 11
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
11: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 12 1 t TT;
5 9 2 ctx Lreactor/util/context/Context;
Signature: (TT;)V
MethodParameters:
Name Flags
t
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aload 1
invokestatic reactor.core.Exceptions.addThrowable:(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Throwable;)Z
ifeq 4
1: aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.done:Z
2: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
invokestatic reactor.core.publisher.Operators.onErrorDropped:(Ljava/lang/Throwable;Lreactor/util/context/Context;)V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 6 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
public void onComplete();
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.FluxConcatMap$ConcatMapDelayed.done:Z
1: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
public void innerNext();
descriptor: (Ljava/lang/Object;)V
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.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 1
invokeinterface reactor.core.CoreSubscriber.onNext:(Ljava/lang/Object;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 2 1 value TR;
Signature: (TR;)V
MethodParameters:
Name Flags
value
public void innerComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
1: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
public void innerError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.currentContext:()Lreactor/util/context/Context;
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
invokestatic reactor.core.publisher.Operators.onNextInnerError:(Ljava/lang/Throwable;Lreactor/util/context/Context;Lorg/reactivestreams/Subscription;)Ljava/lang/Throwable;
astore 1
1: aload 1
ifnull 11
2: getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aload 1
invokestatic reactor.core.Exceptions.addThrowable:(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Throwable;)Z
ifeq 9
3: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.veryEnd:Z
ifne 6
4: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
5: aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.done:Z
6: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
7: aload 0
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.drain:()V
8: goto 12
9: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
invokestatic reactor.core.publisher.Operators.onErrorDropped:(Ljava/lang/Throwable;Lreactor/util/context/Context;)V
10: goto 12
11: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
12: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 13 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void request(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
lload 1
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapInner.request:(J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
0 2 1 n J
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.cancelled:Z
ifne 5
1: aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.cancelled:Z
2: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapInner.cancel:()V
3: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
4: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
aconst_null
invokestatic reactor.core.publisher.Operators.onDiscardQueueWithClear:(Ljava/util/Queue;Lreactor/util/context/Context;Ljava/util/function/Function;)V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=10, args_size=1
start local 0 0: getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement:(Ljava/lang/Object;)I
ifne 74
1: aconst_null
astore 1
start local 1 2: StackMap locals: reactor.util.context.Context
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.cancelled:Z
ifeq 4
3: return
4: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
ifne 73
5: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.done:Z
istore 2
start local 2 6: iload 2
ifeq 13
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.veryEnd:Z
ifne 13
7: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.error:Ljava/lang/Throwable;
astore 3
start local 3 8: aload 3
ifnull 13
9: getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
invokestatic reactor.core.Exceptions.terminate:(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;)Ljava/lang/Throwable;
astore 3
10: aload 3
getstatic reactor.core.Exceptions.TERMINATED:Ljava/lang/Throwable;
if_acmpeq 12
11: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 3
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
12: StackMap locals: int java.lang.Throwable
StackMap stack:
return
end local 3 13: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.queue:Ljava/util/Queue;
invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
astore 3
start local 3 14: goto 18
end local 3 15: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
start local 4 16: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
aload 4
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
17: return
end local 4 start local 3 18: StackMap locals: java.lang.Object
StackMap stack:
aload 3
ifnonnull 19
iconst_1
goto 20
StackMap locals:
StackMap stack:
19: iconst_0
StackMap locals:
StackMap stack: int
20: istore 4
start local 4 21: iload 2
ifeq 28
iload 4
ifeq 28
22: getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
invokestatic reactor.core.Exceptions.terminate:(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;)Ljava/lang/Throwable;
astore 5
start local 5 23: aload 5
ifnull 26
aload 5
getstatic reactor.core.Exceptions.TERMINATED:Ljava/lang/Throwable;
if_acmpeq 26
24: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 5
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
25: goto 27
26: StackMap locals: int java.lang.Throwable
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.onComplete:()V
27: StackMap locals:
StackMap stack:
return
end local 5 28: StackMap locals:
StackMap stack:
iload 4
ifne 73
29: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.mapper:Ljava/util/function/Function;
aload 3
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
30: ldc "The mapper returned a null Publisher"
31: invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.reactivestreams.Publisher
astore 5
start local 5 32: goto 41
end local 5 33: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
start local 6 34: aload 1
ifnonnull 36
35: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
astore 1
36: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context int java.lang.Object int top java.lang.Throwable
StackMap stack:
aload 3
aload 1
invokestatic reactor.core.publisher.Operators.onDiscard:(Ljava/lang/Object;Lreactor/util/context/Context;)V
37: aload 3
aload 6
aload 1
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
invokestatic reactor.core.publisher.Operators.onNextError:(Ljava/lang/Object;Ljava/lang/Throwable;Lreactor/util/context/Context;Lorg/reactivestreams/Subscription;)Ljava/lang/Throwable;
astore 7
start local 7 38: aload 7
ifnull 2
39: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
aload 6
aload 3
aload 1
invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Ljava/lang/Object;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
40: return
end local 7 end local 6 start local 5 41: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context int java.lang.Object int org.reactivestreams.Publisher
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.sourceMode:I
iconst_1
if_icmpeq 48
42: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.consumed:I
iconst_1
iadd
istore 6
start local 6 43: iload 6
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.limit:I
if_icmpne 47
44: aload 0
iconst_0
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.consumed:I
45: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
iload 6
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
46: goto 48
47: StackMap locals: int
StackMap stack:
aload 0
iload 6
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.consumed:I
end local 6 48: StackMap locals:
StackMap stack:
aload 5
instanceof java.util.concurrent.Callable
ifeq 71
49: aload 5
checkcast java.util.concurrent.Callable
50: astore 6
start local 6 51: aload 6
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
astore 7
start local 7 52: goto 63
end local 7 53: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context int java.lang.Object int org.reactivestreams.Publisher java.util.concurrent.Callable
StackMap stack: java.lang.Throwable
astore 8
start local 8 54: aload 1
ifnonnull 56
55: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
astore 1
56: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context int java.lang.Object int org.reactivestreams.Publisher java.util.concurrent.Callable top java.lang.Throwable
StackMap stack:
aload 3
aload 8
aload 1
invokestatic reactor.core.publisher.Operators.onNextError:(Ljava/lang/Object;Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
astore 9
start local 9 57: aload 9
ifnonnull 59
58: goto 2
59: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.veryEnd:Z
ifeq 61
getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.ERROR:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aload 9
invokestatic reactor.core.Exceptions.addThrowable:(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Throwable;)Z
ifeq 61
60: goto 2
61: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.s:Lorg/reactivestreams/Subscription;
aload 9
aload 3
aload 1
invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Ljava/lang/Object;Lreactor/util/context/Context;)Ljava/lang/Throwable;
invokeinterface reactor.core.CoreSubscriber.onError:(Ljava/lang/Throwable;)V
62: return
end local 9 end local 8 start local 7 63: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context int java.lang.Object int org.reactivestreams.Publisher java.util.concurrent.Callable java.lang.Object
StackMap stack:
aload 7
ifnonnull 65
64: goto 2
65: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapInner.isUnbounded:()Z
ifeq 68
66: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.actual:Lreactor/core/CoreSubscriber;
aload 7
invokeinterface reactor.core.CoreSubscriber.onNext:(Ljava/lang/Object;)V
67: goto 2
68: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
69: aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
new reactor.core.publisher.FluxConcatMap$WeakScalarSubscription
dup
aload 7
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
invokespecial reactor.core.publisher.FluxConcatMap$WeakScalarSubscription.<init>:(Ljava/lang/Object;Lreactor/core/CoreSubscriber;)V
invokevirtual reactor.core.publisher.FluxConcatMap$ConcatMapInner.set:(Lorg/reactivestreams/Subscription;)V
end local 7 end local 6 70: goto 73
71: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.active:Z
72: aload 5
aload 0
getfield reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.inner:Lreactor/core/publisher/FluxConcatMap$ConcatMapInner;
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
end local 5 end local 4 end local 3 end local 2 73: StackMap locals: reactor.core.publisher.FluxConcatMap$ConcatMapDelayed reactor.util.context.Context
StackMap stack:
getstatic reactor.core.publisher.FluxConcatMap$ConcatMapDelayed.WIP:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet:(Ljava/lang/Object;)I
ifne 2
end local 1 74: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 75 0 this Lreactor/core/publisher/FluxConcatMap$ConcatMapDelayed<TT;TR;>;
2 74 1 ctx Lreactor/util/context/Context;
6 73 2 d Z
8 13 3 ex Ljava/lang/Throwable;
14 15 3 v TT;
18 73 3 v TT;
16 18 4 e Ljava/lang/Throwable;
21 73 4 empty Z
23 28 5 ex Ljava/lang/Throwable;
32 33 5 p Lorg/reactivestreams/Publisher<+TR;>;
41 73 5 p Lorg/reactivestreams/Publisher<+TR;>;
34 41 6 e Ljava/lang/Throwable;
38 41 7 e_ Ljava/lang/Throwable;
43 48 6 c I
51 70 6 supplier Ljava/util/concurrent/Callable<TR;>;
52 53 7 vr TR;
63 70 7 vr TR;
54 63 8 e Ljava/lang/Throwable;
57 63 9 e_ Ljava/lang/Throwable;
Exception table:
from to target type
13 14 15 Class java.lang.Throwable
29 32 33 Class java.lang.Throwable
51 52 53 Class java.lang.Throwable
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Ljava/lang/Object;Lreactor/core/publisher/FluxConcatMap$FluxConcatMapSupport<TT;TR;>;
SourceFile: "FluxConcatMap.java"
NestHost: reactor.core.publisher.FluxConcatMap
InnerClasses:
public abstract QueueSubscription = reactor.core.Fuseable$QueueSubscription of reactor.core.Fuseable
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
public final RunStyle = reactor.core.Scannable$Attr$RunStyle of reactor.core.Scannable$Attr
final ConcatMapDelayed = reactor.core.publisher.FluxConcatMap$ConcatMapDelayed of reactor.core.publisher.FluxConcatMap
final ConcatMapInner = reactor.core.publisher.FluxConcatMap$ConcatMapInner of reactor.core.publisher.FluxConcatMap
abstract FluxConcatMapSupport = reactor.core.publisher.FluxConcatMap$FluxConcatMapSupport of reactor.core.publisher.FluxConcatMap
final WeakScalarSubscription = reactor.core.publisher.FluxConcatMap$WeakScalarSubscription of reactor.core.publisher.FluxConcatMap