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