vertx / io.vertx.rx.java / RxHelper / observableFuture

observableFuture

open static fun <T : Any> observableFuture(): ObservableFuture<T>

Create a new ObservableFuture<T> object: an rx.Observable implementation implementing Handler<AsyncResult<T>>. When the async result handler completes, the observable will produce the result and complete immediatly after, when it fails it will signal the error.

Return
the observable future.