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