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