final class reactor.core.publisher.FluxBufferTimeout<T, C extends java.util.Collection<? super T>> extends reactor.core.publisher.InternalFluxOperator<T, C>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.publisher.FluxBufferTimeout
super_class: reactor.core.publisher.InternalFluxOperator
{
final int batchSize;
descriptor: I
flags: (0x0010) ACC_FINAL
final java.util.function.Supplier<C> bufferSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/Supplier<TC;>;
final reactor.core.scheduler.Scheduler timer;
descriptor: Lreactor/core/scheduler/Scheduler;
flags: (0x0010) ACC_FINAL
final long timespan;
descriptor: J
flags: (0x0010) ACC_FINAL
final java.util.concurrent.TimeUnit unit;
descriptor: Ljava/util/concurrent/TimeUnit;
flags: (0x0010) ACC_FINAL
void <init>(reactor.core.publisher.Flux<T>, int, long, java.util.concurrent.TimeUnit, reactor.core.scheduler.Scheduler, java.util.function.Supplier<C>);
descriptor: (Lreactor/core/publisher/Flux;IJLjava/util/concurrent/TimeUnit;Lreactor/core/scheduler/Scheduler;Ljava/util/function/Supplier;)V
flags: (0x0000)
Code:
stack=4, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 5 start local 6 start local 7 0: aload 0
aload 1
invokespecial reactor.core.publisher.InternalFluxOperator.<init>:(Lreactor/core/publisher/Flux;)V
1: lload 3
lconst_0
lcmp
ifgt 3
2: new java.lang.IllegalArgumentException
dup
ldc "Timeout period must be strictly positive"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: reactor.core.publisher.FluxBufferTimeout reactor.core.publisher.Flux int long java.util.concurrent.TimeUnit reactor.core.scheduler.Scheduler java.util.function.Supplier
StackMap stack:
iload 2
ifgt 5
4: new java.lang.IllegalArgumentException
dup
ldc "maxSize must be strictly positive"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals:
StackMap stack:
aload 0
aload 6
ldc "Timer"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Scheduler
putfield reactor.core.publisher.FluxBufferTimeout.timer:Lreactor/core/scheduler/Scheduler;
6: aload 0
lload 3
putfield reactor.core.publisher.FluxBufferTimeout.timespan:J
7: aload 0
aload 5
ldc "unit"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.concurrent.TimeUnit
putfield reactor.core.publisher.FluxBufferTimeout.unit:Ljava/util/concurrent/TimeUnit;
8: aload 0
iload 2
putfield reactor.core.publisher.FluxBufferTimeout.batchSize:I
9: aload 0
aload 7
ldc "bufferSupplier"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.Supplier
putfield reactor.core.publisher.FluxBufferTimeout.bufferSupplier:Ljava/util/function/Supplier;
10: return
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lreactor/core/publisher/FluxBufferTimeout<TT;TC;>;
0 11 1 source Lreactor/core/publisher/Flux<TT;>;
0 11 2 maxSize I
0 11 3 timespan J
0 11 5 unit Ljava/util/concurrent/TimeUnit;
0 11 6 timer Lreactor/core/scheduler/Scheduler;
0 11 7 bufferSupplier Ljava/util/function/Supplier<TC;>;
Signature: (Lreactor/core/publisher/Flux<TT;>;IJLjava/util/concurrent/TimeUnit;Lreactor/core/scheduler/Scheduler;Ljava/util/function/Supplier<TC;>;)V
MethodParameters:
Name Flags
source
maxSize
timespan
unit
timer
bufferSupplier
public reactor.core.CoreSubscriber<? super T> subscribeOrReturn(reactor.core.CoreSubscriber<? super C>);
descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new reactor.core.publisher.FluxBufferTimeout$BufferTimeoutSubscriber
dup
1: aload 1
invokestatic reactor.core.publisher.Operators.serialize:(Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
2: aload 0
getfield reactor.core.publisher.FluxBufferTimeout.batchSize:I
3: aload 0
getfield reactor.core.publisher.FluxBufferTimeout.timespan:J
4: aload 0
getfield reactor.core.publisher.FluxBufferTimeout.unit:Ljava/util/concurrent/TimeUnit;
5: aload 0
getfield reactor.core.publisher.FluxBufferTimeout.timer:Lreactor/core/scheduler/Scheduler;
invokeinterface reactor.core.scheduler.Scheduler.createWorker:()Lreactor/core/scheduler/Scheduler$Worker;
6: aload 0
getfield reactor.core.publisher.FluxBufferTimeout.bufferSupplier:Ljava/util/function/Supplier;
7: invokespecial reactor.core.publisher.FluxBufferTimeout$BufferTimeoutSubscriber.<init>:(Lreactor/core/CoreSubscriber;IJLjava/util/concurrent/TimeUnit;Lreactor/core/scheduler/Scheduler$Worker;Ljava/util/function/Supplier;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lreactor/core/publisher/FluxBufferTimeout<TT;TC;>;
0 8 1 actual Lreactor/core/CoreSubscriber<-TC;>;
Signature: (Lreactor/core/CoreSubscriber<-TC;>;)Lreactor/core/CoreSubscriber<-TT;>;
MethodParameters:
Name Flags
actual
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.RUN_ON:Lreactor/core/Scannable$Attr;
if_acmpne 1
aload 0
getfield reactor.core.publisher.FluxBufferTimeout.timer:Lreactor/core/scheduler/Scheduler;
areturn
1: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.RUN_STYLE:Lreactor/core/Scannable$Attr;
if_acmpne 2
getstatic reactor.core.Scannable$Attr$RunStyle.ASYNC:Lreactor/core/Scannable$Attr$RunStyle;
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial reactor.core.publisher.InternalFluxOperator.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/publisher/FluxBufferTimeout<TT;TC;>;
0 3 1 key Lreactor/core/Scannable$Attr;
MethodParameters:
Name Flags
key
}
Signature: <T:Ljava/lang/Object;C::Ljava/util/Collection<-TT;>;>Lreactor/core/publisher/InternalFluxOperator<TT;TC;>;
SourceFile: "FluxBufferTimeout.java"
NestMembers:
reactor.core.publisher.FluxBufferTimeout$BufferTimeoutSubscriber
InnerClasses:
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
public final RunStyle = reactor.core.Scannable$Attr$RunStyle of reactor.core.Scannable$Attr
final BufferTimeoutSubscriber = reactor.core.publisher.FluxBufferTimeout$BufferTimeoutSubscriber of reactor.core.publisher.FluxBufferTimeout
public abstract Worker = reactor.core.scheduler.Scheduler$Worker of reactor.core.scheduler.Scheduler