Uses of Class
io.reactivex.rxjava3.processors.MulticastProcessor

Packages that use MulticastProcessor

Package	Description
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.

Uses of MulticastProcessor in io.reactivex.rxjava3.processors

Fields in io.reactivex.rxjava3.processors declared as MulticastProcessor

Modifier and Type	Field	Description
(package private) MulticastProcessor<T>	MulticastProcessor.MulticastSubscription.parent

Methods in io.reactivex.rxjava3.processors that return MulticastProcessor

Modifier and Type	Method	Description
static <T> @NonNull MulticastProcessor<T>	MulticastProcessor.create()	Constructs a fresh instance with the default Flowable.bufferSize() prefetch amount and no refCount-behavior.
static <T> @NonNull MulticastProcessor<T>	MulticastProcessor.create(boolean refCount)	Constructs a fresh instance with the default Flowable.bufferSize() prefetch amount and the optional refCount-behavior.
static <T> @NonNull MulticastProcessor<T>	MulticastProcessor.create(int bufferSize)	Constructs a fresh instance with the given prefetch amount and no refCount behavior.
static <T> @NonNull MulticastProcessor<T>	MulticastProcessor.create(int bufferSize, boolean refCount)	Constructs a fresh instance with the given prefetch amount and the optional refCount-behavior.

Constructors in io.reactivex.rxjava3.processors with parameters of type MulticastProcessor

Constructor	Description
MulticastSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, MulticastProcessor<@NonNull T> parent)