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


AsyncProcessor<T> Processor 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> Processor that multicasts all subsequently observed items to its current Subscribers. 
ReplayProcessor<T> Replays events to Subscribers. 
UnicastProcessor<T> Processor that allows only a single Subscriber to subscribe to it during its lifetime.