| Class | Description |
|---|---|
| DispatchWorkProcessor<T> |
A
FlowableProcessor variant that queues up items and dispatches them asynchronously
so that one of the currently subscribed Subscribers can pick it up one by
one, otherwise* cache it until at least an Subscriber subscribes. |
| FlowableProcessors |
Utility methods to work with Reactive-Streams Processors and RxJava 2 FlowableProcessors.
|
| MulticastProcessor<T> |
A
Processor implementation that coordinates downstream requrests through
a front-buffer and stable-prefetching, optionally cancelling the upstream if all
subscribers have cancelled. |