Uses of Class
io.reactivex.rxjava3.processors.MulticastProcessor
Packages that use MulticastProcessor
Package
Description
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 MulticastProcessorModifier and TypeFieldDescription(package private) final MulticastProcessor
<T> MulticastProcessor.MulticastSubscription.parent
Methods in io.reactivex.rxjava3.processors that return MulticastProcessorModifier and TypeMethodDescriptionstatic <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 MulticastProcessorModifierConstructorDescription(package private)
MulticastSubscription
(org.reactivestreams.Subscriber<? super @NonNull T> actual, MulticastProcessor<@NonNull T> parent)