Package hu.akarnokd.rxjava3.async

Utility methods to jumpstart a reactive sequence via AsyncFlowable and AsyncObservable; port of the RxJavaAsyncUtil library.

Class Summary

Class	Description
AsyncFlowable	Utility methods to convert functions and actions into asynchronous operations through the Publisher/Subscriber pattern.
AsyncObservable	Utility methods to convert functions and actions into asynchronous operations through the Observable/Observer pattern.
DisposableFlowable<T>	A Flowable that also offers a means to dispose it, cancelling/disposing some shared underlying computation or resource via Disposable.dispose().
DisposableObservable<T>	A Observable that also offers a means to dispose it, cancelling/disposing some shared underlying computation or resource via Disposable.dispose().

Enum Summary

Enum	Description
AnyValue	Placeholder instance when one has to return something (and used to return null in 1.x).