interface reactor.core.publisher.FluxReplay$ReplayBuffer<T>
minor version: 0
major version: 59
flags: flags: (0x0600) ACC_INTERFACE, ACC_ABSTRACT
this_class: reactor.core.publisher.FluxReplay$ReplayBuffer
super_class: java.lang.Object
{
public abstract void add();
descriptor: (Ljava/lang/Object;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (TT;)V
MethodParameters:
Name Flags
value
public abstract void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
ex
public abstract java.lang.Throwable getError();
descriptor: ()Ljava/lang/Throwable;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
public abstract void onComplete();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract void replay(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)V
MethodParameters:
Name Flags
rs
public abstract boolean isDone();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract T poll(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)Ljava/lang/Object;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)TT;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
rs
public abstract void clear(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)V
MethodParameters:
Name Flags
rs
public abstract boolean isEmpty(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)Z
MethodParameters:
Name Flags
rs
public abstract int size(reactor.core.publisher.FluxReplay$ReplaySubscription<T>);
descriptor: (Lreactor/core/publisher/FluxReplay$ReplaySubscription;)I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lreactor/core/publisher/FluxReplay$ReplaySubscription<TT;>;)I
MethodParameters:
Name Flags
rs
public abstract int size();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract int capacity();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract boolean isExpired();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "FluxReplay.java"
NestHost: reactor.core.publisher.FluxReplay
InnerClasses:
abstract ReplayBuffer = reactor.core.publisher.FluxReplay$ReplayBuffer of reactor.core.publisher.FluxReplay
abstract ReplaySubscription = reactor.core.publisher.FluxReplay$ReplaySubscription of reactor.core.publisher.FluxReplay