open class FlowableUnmarshaller<T : Any, B : Any> : FlowableTransformer<B, T>
An operator to unmarshall json to pojos.
Author
Julien Viet
FlowableUnmarshaller(unwrap: Function<B, Buffer>, mappedType: Class<T>)FlowableUnmarshaller(unwrap: Function<B, Buffer>, mappedTypeRef: TypeReference<T>) |
open fun apply(upstream: Flowable<B>): Publisher<T> |