vertx / io.vertx.reactivex / SingleHelper

SingleHelper

open class SingleHelper

Author
Julien Viet

Constructors

<init>

SingleHelper()

Functions

toObserver

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

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

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

unmarshaller

open static fun <T : Any> unmarshaller(mappedType: Class<T>): SingleTransformer<Buffer, T>
open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>): SingleTransformer<Buffer, T>
open static fun <T : Any> unmarshaller(mappedType: Class<T>, mapper: ObjectMapper): SingleTransformer<Buffer, T>
open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>, mapper: ObjectMapper): SingleTransformer<Buffer, T>