Package hu.akarnokd.rxjava3.processors

Special processors such as DispatchWorkProcessor and generic utilities for FlowableProcessors via FlowableProcessors methods.

Class Summary

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.