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.