Package 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.

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.rxjava3.subjects

Interface Summary

Interface	Description
ReplayProcessor.ReplayBuffer<T>	Abstraction over a buffer that receives events and replays them to individual Subscribers.

Class Summary

Class	Description
AsyncProcessor<T>	Processor that emits the very last value followed by a completion event or the received error to Subscribers.
AsyncProcessor.AsyncSubscription<T>
BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Subscriber.
BehaviorProcessor.BehaviorSubscription<T>
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.
MulticastProcessor.MulticastSubscription<T>
PublishProcessor<T>	Processor that multicasts all subsequently observed items to its current Subscribers.
PublishProcessor.PublishSubscription<T>	Wraps the actual subscriber, tracks its requests and makes cancellation to remove itself from the current subscribers array.
ReplayProcessor<T>	Replays events to Subscribers.
ReplayProcessor.Node<T>
ReplayProcessor.ReplaySubscription<T>
ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>
ReplayProcessor.SizeBoundReplayBuffer<T>
ReplayProcessor.TimedNode<T>
ReplayProcessor.UnboundedReplayBuffer<T>
SerializedProcessor<T>	Serializes calls to the Subscriber methods.
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.