| 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> | Deprecated
in 0.19.2 - will be removed in 0.20.
|