vertx / io.vertx.reactivex / ObservableHelper / toReadStream

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

Parameters

observable - the observable to adapt

Return
the adapted stream