Package hu.akarnokd.rxjava3.subjects

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

See: Description

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.

Package hu.akarnokd.rxjava3.subjects Description

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