Package io.reactivex.processors

Classes extending the Flowable base reactive class and implementing the Subscriber interface at the same time (aka hot Flowables).

See: Description

Class Summary

Class	Description
AsyncProcessor<T>	A Subject that emits the very last value followed by a completion event or the received error to Subscribers.
BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed 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.
PublishProcessor<T>	A Subject that multicasts events to Subscribers that are currently subscribed to it.
ReplayProcessor<T>	Replays events to Subscribers.
UnicastProcessor<T>	Processor that allows only a single Subscriber to subscribe to it during its lifetime.

Package io.reactivex.processors Description

Classes extending the Flowable base reactive class and implementing the Subscriber interface at the same time (aka hot Flowables).