async

open fun <R> async(block: (T, Observer<R>) -> Disposable): Observable<R>

Returns an observable that will emit values in a possibly asynchronous manner determined by the given block.

Parameters

block

a block of code, to be executed with the next value from the source, along with the observer with which to emit downstream.