vertx / io.vertx.reactivex / ObservableHelper

# ObservableHelper

`open class ObservableHelper`

Author
Julien Viet

### Constructors

<init> | `ObservableHelper()`

### Functions

toObservable | `open static fun <T : Any> toObservable(stream: ReadStream<T>): Observable<T>` Adapts a Vert.x ReadStream to an RxJava Observable. After the stream is adapted to an observable, the original stream handlers should not be used anymore as they will be used by the observable adapter. `open static fun <T : Any, U : Any> toObservable(stream: ReadStream<T>, mapping: Function<T, U>): Observable<U>` Like `#toObservable(ReadStream)` but with a `mapping` function
toReadStream | `open static fun <T : Any> toReadStream(observable: Observable<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>): ObservableTransformer<Buffer, T>` `open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>): ObservableTransformer<Buffer, T>` `open static fun <T : Any> unmarshaller(mappedType: Class<T>, mapper: ObjectMapper): ObservableTransformer<Buffer, T>` `open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>, mapper: ObjectMapper): ObservableTransformer<Buffer, T>`