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