Package io.reactivex.rxjava4.processors

package io.reactivex.rxjava4.processors

Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams

invalid reference

Processor

interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams

invalid reference

Publisher

.

Available processor implementations:

• AsyncProcessor - replays the very last item
• BehaviorProcessor - remembers the latest item
• MulticastProcessor - coordinates its source with its consumers
• PublishProcessor - dispatches items to current consumers
• ReplayProcessor - remembers some or all items and replays them to consumers
• UnicastProcessor - remembers or relays items to a single consumer

The non-backpressured variants of the FlowableProcessor class are called Subjects and reside in the io.reactivex.subjects package.

See Also:

• io.reactivex.rxjava4.subjects

Classes

Class	Description
AsyncProcessor<T>	Processor that emits the very last value followed by a completion event or the received error to Flow.Subscribers.
BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Flow.Subscriber.
FlowableProcessor<T>	Represents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.
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.
PublishProcessor<T>	Processor that multicasts all subsequently observed items to its current Flow.Subscribers.
ReplayProcessor<T>	Replays events to Subscribers.
UnicastProcessor<T>	A FlowableProcessor variant that queues up events until a single Flow.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.