Package hu.akarnokd.rxjava3.subjects

Special subjects such as UnicastWorkSubject, DispatchWorkSubject and generic utilities for Subjects via Subjects methods.

Class Summary

Class	Description
DispatchWorkSubject<T>	A Subject variant that queues up items and dispatches them asynchronously so that one of the currently subscribed Observers can pick it up one by one, otherwise* cache it until at least an Observer subscribes.
Subjects	Utility methods to work with RxJava 2 Subjects.
UnicastWorkSubject<T>	A Subject that holds an unbounded queue of items and relays/replays it to a single Observer at a time, making sure that when the Observer disposes, any unconsumed items are available for the next Observer.