vertx / io.vertx.rxjava.core / RxHelper / unmarshaller

unmarshaller

open static fun <T : Any> unmarshaller(mappedType: Class<T>): Operator<T, Buffer>

Returns a json unmarshaller for the specified java type as a rx.Observable.Operator instance. The marshaller can be used with the rx.Observable#lift(rx.Observable.Operator) method to transform a Observable<Buffer> into a Observable<T>. The unmarshaller buffers the content until onComplete is called, then unmarshalling happens. Note that the returned observable will emit at most a single object.

Parameters

mappedType - the type to unmarshall

Return
the unmarshaller operator