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 itemBehaviorProcessor
- remembers the latest itemMulticastProcessor
- coordinates its source with its consumersPublishProcessor
- dispatches items to current consumersReplayProcessor
- remembers some or all items and replays them to consumersUnicastProcessor
- remembers or relays items to a single consumer
The non-backpressured variants of the FlowableProcessor
class are called
Subject
s 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 toSubscriber
s.AsyncProcessor.AsyncSubscription<T> BehaviorProcessor<T> Processor that emits the most recent item it has observed and all subsequent observed items to each subscribedSubscriber
.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> AFlowableProcessor
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 currentSubscriber
s.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> AFlowableProcessor
variant that queues up events until a singleSubscriber
subscribes to it, replays those events to it until theSubscriber
catches up and then switches to relaying events live to this singleSubscriber
until thisUnicastProcessor
terminates or theSubscriber
cancels its subscription.