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

Packages that use UnicastProcessor

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 UnicastProcessor in io.reactivex.rxjava3.processors

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

Modifier and Type	Method	Description
static <T> @NonNull UnicastProcessor<T>	UnicastProcessor.create()	Creates an UnicastSubject with an internal buffer capacity hint 16.
static <T> @NonNull UnicastProcessor<T>	UnicastProcessor.create(boolean delayError)	Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag.
static <T> @NonNull UnicastProcessor<T>	UnicastProcessor.create(int capacityHint)	Creates an UnicastProcessor with the given internal buffer capacity hint.
static <T> @NonNull UnicastProcessor<T>	UnicastProcessor.create(int capacityHint, @NonNull Runnable onTerminate)	Creates an UnicastProcessor with the given internal buffer capacity hint and a callback for the case when the single Subscriber cancels its subscription or the processor is terminated.
static <T> @NonNull UnicastProcessor<T>	UnicastProcessor.create(int capacityHint, @NonNull Runnable onTerminate, boolean delayError)	Creates an UnicastProcessor with the given internal buffer capacity hint, delay error flag and a callback for the case when the single Subscriber cancels its subscription or the processor is terminated.