vertx / io.vertx.rx.java / RxHelper / toSubscriber

toSubscriber

open static fun <T : Any> toSubscriber(handler: Handler<AsyncResult<T>>): Subscriber<T>

Adapts an Vert.x Handler<AsyncResult<T>> to an RxJava Subscriber.

The returned subscriber can be subscribed to an Observable#subscribe(Subscriber) or rx.Single#subscribe(Subscriber).

Parameters

handler - the handler to adapt

Return
the subscriber