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