RxJava 2 2.2.21 · io.reactivex.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 io.reactivex.subjects.Subjects and reside in the io.reactivex.subjects package.

Class Summary

Modifier and Type	Class and Description
public class	AsyncProcessor< the value type T> Processor that emits the very last value followed by a completion event or the received error to `Subscriber`s.
public class	BehaviorProcessor< the type of item expected to be observed and emitted by the Processor T> Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed `Subscriber`.
public abstract class	FlowableProcessor< the item value type T> Represents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.
public class	MulticastProcessor< the input and output value type T> A `FlowableProcessor` implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.
public class	PublishProcessor< the value type multicasted to Subscribers. T> Processor that multicasts all subsequently observed items to its current `Subscriber`s.
public class	ReplayProcessor< the value type T> Replays events to Subscribers.
pack-priv class	SerializedProcessor< the item value type T> Serializes calls to the Subscriber methods.
public class	UnicastProcessor< the value type received and emitted by this Processor subclass 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.

Package io.reactivex.processors

Class Summary