vertx / io.vertx.rx.java / ReadStreamSubscriber / asReadStream

asReadStream

open static fun <R : Any, J : Any> asReadStream(observable: Observable<R>, adapter: Function<R, J>): ReadStream<J>