vertx / io.vertx.reactivex / FlowableHelper

FlowableHelper

open class FlowableHelper

Author
Julien Viet

Constructors

<init>

FlowableHelper()

Functions

toFlowable

open static fun <T : Any, U : Any> toFlowable(stream: ReadStream<T>, mapping: Function<T, U>): Flowable<U>

Like #toFlowable(ReadStream) but with a mapping function

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.

toReadStream

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 <.

unmarshaller

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>