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.
Return
the adapted observable