vertx / io.vertx.reactivex / ObservableHelper / toObservable

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.

Parameters

stream - the stream to adapt

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