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

Packages that use FlowableProcessor

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

Subclasses of FlowableProcessor in io.reactivex.rxjava3.processors

Modifier and Type	Class	Description
final class	AsyncProcessor<T>	Processor that emits the very last value followed by a completion event or the received error to Subscribers.
final class	BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Subscriber.
final class	MulticastProcessor<T>	A FlowableProcessor implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.
final class	PublishProcessor<T>	Processor that multicasts all subsequently observed items to its current Subscribers.
final class	ReplayProcessor<T>	Replays events to Subscribers.
final class	UnicastProcessor<T>	A FlowableProcessor variant that queues up events until a single Subscriber subscribes to it, replays those events to it until the Subscriber catches up and then switches to relaying events live to this single Subscriber until this UnicastProcessor terminates or the Subscriber cancels its subscription.

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

Modifier and Type	Method	Description
final @NonNull FlowableProcessor<T>	FlowableProcessor.toSerialized()	Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.