vertx / io.vertx.reactivex / MaybeHelper / toObserver

toObserver

open static fun <T : Any> toObserver(handler: Handler<AsyncResult<T>>): MaybeObserver<T>

Adapts an Vert.x Handler<AsyncResult<T>> to an RxJava2 SingleObserver.

The returned observer can be subscribed to an Single#subscribe(SingleObserver).

Parameters

handler - the handler to adapt

Return
the observer