public interface reactor.core.publisher.Sinks$MulticastSpec
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: reactor.core.publisher.Sinks$MulticastSpec
super_class: java.lang.Object
{
public abstract <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer();
descriptor: ()Lreactor/core/publisher/Sinks$Many;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;
public abstract <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer(int);
descriptor: (I)Lreactor/core/publisher/Sinks$Many;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T:Ljava/lang/Object;>(I)Lreactor/core/publisher/Sinks$Many<TT;>;
MethodParameters:
Name Flags
bufferSize
public abstract <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer(int, boolean);
descriptor: (IZ)Lreactor/core/publisher/Sinks$Many;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T:Ljava/lang/Object;>(IZ)Lreactor/core/publisher/Sinks$Many<TT;>;
MethodParameters:
Name Flags
bufferSize
autoCancel
public abstract <T> reactor.core.publisher.Sinks$Many<T> directAllOrNothing();
descriptor: ()Lreactor/core/publisher/Sinks$Many;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;
public abstract <T> reactor.core.publisher.Sinks$Many<T> directBestEffort();
descriptor: ()Lreactor/core/publisher/Sinks$Many;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;
}
SourceFile: "Sinks.java"
NestHost: reactor.core.publisher.Sinks
InnerClasses:
public abstract Many = reactor.core.publisher.Sinks$Many of reactor.core.publisher.Sinks
public abstract MulticastSpec = reactor.core.publisher.Sinks$MulticastSpec of reactor.core.publisher.Sinks