Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
Classes
| 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. |