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.