open class FlowableHelper
Author
Julien Viet
FlowableHelper() |
open static fun <T : Any, U : Any> toFlowable(stream: ReadStream<T>, mapping: Function<T, U>): Flowable<U>
Like open static fun <T : Any> toFlowable(stream: ReadStream<T>): Flowable<T>open static fun <T : Any> toFlowable(stream: ReadStream<T>, maxBufferSize: Long): Flowable<T>
Adapts a Vert.x < to an RxJava <. After the stream is adapted to a flowable, the original stream handlers should not be used anymore as they will be used by the flowable adapter. |
|
open static fun <T : Any> toReadStream(observable: Flowable<T>): ReadStream<T>
Adapts an RxJava < to a Vert.x <. The returned readstream will be subscribed to the <. |
|
open static fun <T : Any> unmarshaller(mappedType: Class<T>): FlowableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>): FlowableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedType: Class<T>, mapper: ObjectMapper): FlowableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>, mapper: ObjectMapper): FlowableTransformer<Buffer, T> |