vertx / io.vertx.reactivex / FlowableHelper / toFlowable

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.

Parameters

stream - the stream to adapt

Return
the adapted observable