public final class reactor.core.publisher.ReplayProcessor<T> extends reactor.core.publisher.FluxProcessor<T, T> implements reactor.core.Fuseable
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.ReplayProcessor
super_class: reactor.core.publisher.FluxProcessor
{
final reactor.core.publisher.FluxReplay$ReplayBuffer<T> buffer;
descriptor: Lreactor/core/publisher/FluxReplay$ReplayBuffer;
flags: (0x0010) ACC_FINAL
Signature: Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;
org.reactivestreams.Subscription subscription;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
volatile reactor.core.publisher.FluxReplay$ReplaySubscription<T>[] subscribers;
descriptor: [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
flags: (0x0040) ACC_VOLATILE
Signature: [Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<reactor.core.publisher.ReplayProcessor, reactor.core.publisher.FluxReplay$ReplaySubscription[]> SUBSCRIBERS;
descriptor: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<Lreactor/core/publisher/ReplayProcessor;[Lreactor/core/publisher/FluxReplay$ReplaySubscription;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lreactor/core/publisher/ReplayProcessor;
1: ldc [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
2: ldc "subscribers"
3: invokestatic java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
putstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
4: return
LocalVariableTable:
Start End Slot Name Signature
public static <T> reactor.core.publisher.ReplayProcessor<T> cacheLast();
descriptor: ()Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: aconst_null
invokestatic reactor.core.publisher.ReplayProcessor.cacheLastOrDefault:(Ljava/lang/Object;)Lreactor/core/publisher/ReplayProcessor;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/ReplayProcessor<TT;>;
public static <T> reactor.core.publisher.ReplayProcessor<T> cacheLastOrDefault(T);
descriptor: (Ljava/lang/Object;)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: iconst_1
invokestatic reactor.core.publisher.ReplayProcessor.create:(I)Lreactor/core/publisher/ReplayProcessor;
astore 1
start local 1 1: aload 0
ifnull 3
2: aload 1
aload 0
invokevirtual reactor.core.publisher.ReplayProcessor.onNext:(Ljava/lang/Object;)V
3: StackMap locals: reactor.core.publisher.ReplayProcessor
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 value TT;
1 4 1 b Lreactor/core/publisher/ReplayProcessor<TT;>;
Signature: <T:Ljava/lang/Object;>(TT;)Lreactor/core/publisher/ReplayProcessor<TT;>;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
value
public static <E> reactor.core.publisher.ReplayProcessor<E> create();
descriptor: ()Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
iconst_1
invokestatic reactor.core.publisher.ReplayProcessor.create:(IZ)Lreactor/core/publisher/ReplayProcessor;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <E:Ljava/lang/Object;>()Lreactor/core/publisher/ReplayProcessor<TE;>;
public static <E> reactor.core.publisher.ReplayProcessor<E> create(int);
descriptor: (I)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: iload 0
iconst_0
invokestatic reactor.core.publisher.ReplayProcessor.create:(IZ)Lreactor/core/publisher/ReplayProcessor;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 historySize I
Signature: <E:Ljava/lang/Object;>(I)Lreactor/core/publisher/ReplayProcessor<TE;>;
MethodParameters:
Name Flags
historySize
public static <E> reactor.core.publisher.ReplayProcessor<E> create(int, boolean);
descriptor: (IZ)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: iload 1
ifeq 3
1: new reactor.core.publisher.FluxReplay$UnboundedReplayBuffer
dup
iload 0
invokespecial reactor.core.publisher.FluxReplay$UnboundedReplayBuffer.<init>:(I)V
astore 2
start local 2 2: goto 4
end local 2 3: StackMap locals:
StackMap stack:
new reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer
dup
iload 0
invokespecial reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer.<init>:(I)V
astore 2
start local 2 4: StackMap locals: reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
new reactor.core.publisher.ReplayProcessor
dup
aload 2
invokespecial reactor.core.publisher.ReplayProcessor.<init>:(Lreactor/core/publisher/FluxReplay$ReplayBuffer;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 historySize I
0 5 1 unbounded Z
2 3 2 buffer Lreactor/core/publisher/FluxReplay$ReplayBuffer<TE;>;
4 5 2 buffer Lreactor/core/publisher/FluxReplay$ReplayBuffer<TE;>;
Signature: <E:Ljava/lang/Object;>(IZ)Lreactor/core/publisher/ReplayProcessor<TE;>;
MethodParameters:
Name Flags
historySize
unbounded
public static <T> reactor.core.publisher.ReplayProcessor<T> createTimeout(java.time.Duration);
descriptor: (Ljava/time/Duration;)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic reactor.core.scheduler.Schedulers.parallel:()Lreactor/core/scheduler/Scheduler;
invokestatic reactor.core.publisher.ReplayProcessor.createTimeout:(Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 maxAge Ljava/time/Duration;
Signature: <T:Ljava/lang/Object;>(Ljava/time/Duration;)Lreactor/core/publisher/ReplayProcessor<TT;>;
MethodParameters:
Name Flags
maxAge
public static <T> reactor.core.publisher.ReplayProcessor<T> createTimeout(java.time.Duration, reactor.core.scheduler.Scheduler);
descriptor: (Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: ldc 2147483647
aload 0
aload 1
invokestatic reactor.core.publisher.ReplayProcessor.createSizeAndTimeout:(ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 maxAge Ljava/time/Duration;
0 1 1 scheduler Lreactor/core/scheduler/Scheduler;
Signature: <T:Ljava/lang/Object;>(Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor<TT;>;
MethodParameters:
Name Flags
maxAge
scheduler
public static <T> reactor.core.publisher.ReplayProcessor<T> createSizeAndTimeout(int, java.time.Duration);
descriptor: (ILjava/time/Duration;)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: iload 0
aload 1
invokestatic reactor.core.scheduler.Schedulers.parallel:()Lreactor/core/scheduler/Scheduler;
invokestatic reactor.core.publisher.ReplayProcessor.createSizeAndTimeout:(ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 size I
0 1 1 maxAge Ljava/time/Duration;
Signature: <T:Ljava/lang/Object;>(ILjava/time/Duration;)Lreactor/core/publisher/ReplayProcessor<TT;>;
MethodParameters:
Name Flags
size
maxAge
public static <T> reactor.core.publisher.ReplayProcessor<T> createSizeAndTimeout(int, java.time.Duration, reactor.core.scheduler.Scheduler);
descriptor: (ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ldc "scheduler is null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 0
ifgt 3
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "size > 0 required but it was "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 0
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
new reactor.core.publisher.ReplayProcessor
dup
new reactor.core.publisher.FluxReplay$SizeAndTimeBoundReplayBuffer
dup
iload 0
4: aload 1
invokevirtual java.time.Duration.toMillis:()J
5: aload 2
invokespecial reactor.core.publisher.FluxReplay$SizeAndTimeBoundReplayBuffer.<init>:(IJLreactor/core/scheduler/Scheduler;)V
6: invokespecial reactor.core.publisher.ReplayProcessor.<init>:(Lreactor/core/publisher/FluxReplay$ReplayBuffer;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 size I
0 7 1 maxAge Ljava/time/Duration;
0 7 2 scheduler Lreactor/core/scheduler/Scheduler;
Signature: <T:Ljava/lang/Object;>(ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor<TT;>;
MethodParameters:
Name Flags
size
maxAge
scheduler
void <init>(reactor.core.publisher.FluxReplay$ReplayBuffer<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplayBuffer;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial reactor.core.publisher.FluxProcessor.<init>:()V
1: aload 0
aload 1
putfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
2: getstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.EMPTY:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.lazySet:(Ljava/lang/Object;Ljava/lang/Object;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 4 1 buffer Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;
Signature: (Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;)V
MethodParameters:
Name Flags
buffer
public void subscribe(reactor.core.CoreSubscriber<? super T>);
descriptor: (Lreactor/core/CoreSubscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "subscribe"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new reactor.core.publisher.ReplayProcessor$ReplayInner
dup
aload 1
aload 0
invokespecial reactor.core.publisher.ReplayProcessor$ReplayInner.<init>:(Lreactor/core/CoreSubscriber;Lreactor/core/publisher/ReplayProcessor;)V
astore 2
start local 2 2: aload 1
aload 2
invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
3: aload 0
aload 2
invokevirtual reactor.core.publisher.ReplayProcessor.add:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)Z
ifeq 7
4: aload 2
invokeinterface reactor.core.publisher.FluxReplay$ReplaySubscription.isCancelled:()Z
ifeq 7
5: aload 0
aload 2
invokevirtual reactor.core.publisher.ReplayProcessor.remove:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
6: return
7: StackMap locals: reactor.core.publisher.FluxReplay$ReplaySubscription
StackMap stack:
aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
aload 2
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.replay:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 9 1 actual Lreactor/core/CoreSubscriber<-TT;>;
2 9 2 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
Signature: (Lreactor/core/CoreSubscriber<-TT;>;)V
MethodParameters:
Name Flags
actual
public java.lang.Throwable getError();
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.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.getError:()Ljava/lang/Throwable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
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 2
1: aload 0
getfield reactor.core.publisher.ReplayProcessor.subscription:Lorg/reactivestreams/Subscription;
areturn
2: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.CAPACITY:Lreactor/core/Scannable$Attr;
if_acmpne 3
aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.capacity:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial reactor.core.publisher.FluxProcessor.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 4 1 key Lreactor/core/Scannable$Attr;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
key
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.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
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/ReplayProcessor<TT;>;
Signature: ()Ljava/util/stream/Stream<+Lreactor/core/Scannable;>;
public long downstreamCount();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
arraylength
i2l
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
public boolean isTerminated();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.isDone:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
boolean add(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)Z
flags: (0x0000)
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
astore 2
start local 2 1: aload 2
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.TERMINATED:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
if_acmpne 3
2: iconst_0
ireturn
3: StackMap locals: reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
aload 2
arraylength
istore 3
start local 3 4: iload 3
iconst_1
iadd
anewarray reactor.core.publisher.ReplayProcessor$ReplayInner
5: astore 4
start local 4 6: aload 2
iconst_0
aload 4
iconst_0
iload 3
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
7: aload 4
iload 3
aload 1
aastore
8: getstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aload 2
aload 4
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
9: iconst_1
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 10 1 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
1 10 2 a [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
4 10 3 n I
6 10 4 b [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)Z
MethodParameters:
Name Flags
rs
void remove(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
flags: (0x0000)
Code:
stack=6, locals=6, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
astore 2
start local 2 1: aload 2
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.TERMINATED:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
if_acmpeq 2
aload 2
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.EMPTY:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
if_acmpne 3
2: StackMap locals: reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
return
3: StackMap locals:
StackMap stack:
aload 2
arraylength
istore 3
start local 3 4: iconst_0
istore 4
start local 4 5: goto 16
6: StackMap locals: int int
StackMap stack:
aload 2
iload 4
aaload
aload 1
if_acmpne 15
7: iload 3
iconst_1
if_icmpne 10
8: getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.EMPTY:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
astore 5
start local 5 9: goto 13
end local 5 10: StackMap locals:
StackMap stack:
iload 3
iconst_1
isub
anewarray reactor.core.publisher.ReplayProcessor$ReplayInner
astore 5
start local 5 11: aload 2
iconst_0
aload 5
iconst_0
iload 4
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
12: aload 2
iload 4
iconst_1
iadd
aload 5
iload 4
iload 3
iload 4
isub
iconst_1
isub
invokestatic java.lang.System.arraycopy:(Ljava/lang/Object;ILjava/lang/Object;II)V
13: StackMap locals: reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
getstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
aload 2
aload 5
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
14: return
end local 5 15: StackMap locals:
StackMap stack:
iinc 4 1
StackMap locals:
StackMap stack:
16: iload 4
iload 3
if_icmplt 6
end local 4 end local 3 end local 2 17: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 18 1 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
1 17 2 a [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
4 17 3 n I
5 17 4 i I
9 10 5 b [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
11 15 5 b [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)V
MethodParameters:
Name Flags
rs
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.isDone:()Z
ifeq 3
1: aload 1
invokeinterface org.reactivestreams.Subscription.cancel:()V
2: goto 6
3: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.publisher.ReplayProcessor.subscription:Lorg/reactivestreams/Subscription;
aload 1
invokestatic reactor.core.publisher.Operators.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 6
4: aload 0
aload 1
putfield reactor.core.publisher.ReplayProcessor.subscription:Lorg/reactivestreams/Subscription;
5: aload 1
ldc 9223372036854775807
invokeinterface org.reactivestreams.Subscription.request:(J)V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 7 1 s Lorg/reactivestreams/Subscription;
MethodParameters:
Name Flags
s
public reactor.util.context.Context currentContext();
descriptor: ()Lreactor/util/context/Context;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
invokestatic reactor.core.publisher.Operators.multiSubscribersContext:([Lreactor/core/publisher/InnerProducer;)Lreactor/util/context/Context;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
public int getPrefetch();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: ldc 2147483647
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
astore 2
start local 2 1: aload 2
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.isDone:()Z
ifeq 4
2: aload 1
aload 0
invokevirtual reactor.core.publisher.ReplayProcessor.currentContext:()Lreactor/util/context/Context;
invokestatic reactor.core.publisher.Operators.onNextDropped:(Ljava/lang/Object;Lreactor/util/context/Context;)V
3: goto 10
4: StackMap locals: reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
aload 2
aload 1
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.add:(Ljava/lang/Object;)V
5: aload 0
getfield reactor.core.publisher.ReplayProcessor.subscribers:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 9
StackMap locals: reactor.core.publisher.ReplayProcessor java.lang.Object reactor.core.publisher.FluxReplay$ReplayBuffer top int int reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
6: aload 6
iload 4
aaload
astore 3
start local 3 7: aload 2
aload 3
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.replay:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
end local 3 8: iinc 4 1
StackMap locals:
StackMap stack:
9: iload 4
iload 5
if_icmplt 6
10: StackMap locals: reactor.core.publisher.ReplayProcessor java.lang.Object reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 11 1 t TT;
1 11 2 b Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;
7 8 3 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
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=8, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
astore 2
start local 2 1: aload 2
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.isDone:()Z
ifeq 4
2: aload 1
invokestatic reactor.core.publisher.Operators.onErrorDroppedMulticast:(Ljava/lang/Throwable;)V
3: goto 12
4: StackMap locals: reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
aload 2
aload 1
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.onError:(Ljava/lang/Throwable;)V
5: getstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.TERMINATED:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.FluxReplay$ReplaySubscription[]
6: astore 3
start local 3 7: aload 3
dup
astore 7
arraylength
istore 6
iconst_0
istore 5
goto 11
StackMap locals: reactor.core.publisher.ReplayProcessor java.lang.Throwable reactor.core.publisher.FluxReplay$ReplayBuffer reactor.core.publisher.FluxReplay$ReplaySubscription[] top int int reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
8: aload 7
iload 5
aaload
astore 4
start local 4 9: aload 2
aload 4
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.replay:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
end local 4 10: iinc 5 1
StackMap locals:
StackMap stack:
11: iload 5
iload 6
if_icmplt 8
end local 3 12: StackMap locals: reactor.core.publisher.ReplayProcessor java.lang.Throwable reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
0 13 1 t Ljava/lang/Throwable;
1 13 2 b Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;
7 12 3 a [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
9 10 4 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
MethodParameters:
Name Flags
t
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=7, args_size=1
start local 0 0: aload 0
getfield reactor.core.publisher.ReplayProcessor.buffer:Lreactor/core/publisher/FluxReplay$ReplayBuffer;
astore 1
start local 1 1: aload 1
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.isDone:()Z
ifne 10
2: aload 1
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.onComplete:()V
3: getstatic reactor.core.publisher.ReplayProcessor.SUBSCRIBERS:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
aload 0
getstatic reactor.core.publisher.FluxReplay$ReplaySubscriber.TERMINATED:[Lreactor/core/publisher/FluxReplay$ReplaySubscription;
invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.publisher.FluxReplay$ReplaySubscription[]
4: astore 2
start local 2 5: aload 2
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 9
StackMap locals: reactor.core.publisher.ReplayProcessor reactor.core.publisher.FluxReplay$ReplayBuffer reactor.core.publisher.FluxReplay$ReplaySubscription[] top int int reactor.core.publisher.FluxReplay$ReplaySubscription[]
StackMap stack:
6: aload 6
iload 4
aaload
astore 3
start local 3 7: aload 1
aload 3
invokeinterface reactor.core.publisher.FluxReplay$ReplayBuffer.replay:(Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
end local 3 8: iinc 4 1
StackMap locals:
StackMap stack:
9: iload 4
iload 5
if_icmplt 6
end local 2 10: StackMap locals: reactor.core.publisher.ReplayProcessor reactor.core.publisher.FluxReplay$ReplayBuffer
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/ReplayProcessor<TT;>;
1 11 1 b Lreactor/core/publisher/FluxReplay$ReplayBuffer<TT;>;
5 10 2 a [Lreactor/core/publisher/FluxReplay$ReplaySubscription;
7 8 3 rs Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;
}
Signature: <T:Ljava/lang/Object;>Lreactor/core/publisher/FluxProcessor<TT;TT;>;Lreactor/core/Fuseable;
SourceFile: "ReplayProcessor.java"
NestMembers:
reactor.core.publisher.ReplayProcessor$ReplayInner
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
abstract ReplayBuffer = reactor.core.publisher.FluxReplay$ReplayBuffer of reactor.core.publisher.FluxReplay
final ReplaySubscriber = reactor.core.publisher.FluxReplay$ReplaySubscriber of reactor.core.publisher.FluxReplay
abstract ReplaySubscription = reactor.core.publisher.FluxReplay$ReplaySubscription of reactor.core.publisher.FluxReplay
final SizeAndTimeBoundReplayBuffer = reactor.core.publisher.FluxReplay$SizeAndTimeBoundReplayBuffer of reactor.core.publisher.FluxReplay
final SizeBoundReplayBuffer = reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer of reactor.core.publisher.FluxReplay
final UnboundedReplayBuffer = reactor.core.publisher.FluxReplay$UnboundedReplayBuffer of reactor.core.publisher.FluxReplay
final ReplayInner = reactor.core.publisher.ReplayProcessor$ReplayInner of reactor.core.publisher.ReplayProcessor