Package hu.akarnokd.rxjava3.async

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

See: Description

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).

Package hu.akarnokd.rxjava3.async Description

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