Module Async_extended.Reader_ext

val input_sexps : Async.Reader.t ‑> Async.Sexp.t list Async.Deferred.t

val open_gzip_file : string ‑> Async.Reader.t Async.Deferred.t

val with_input_from_process : prog:string ‑> args:string list ‑> f:(Async.Reader.t ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t

Start a process and read its stdout as input from a Reader.t.

If the process writes anything to stderr it will be thrown as an exception after reading is finished.

val with_gzip_file : string ‑> f:(Async.Reader.t ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t

val with_hadoop_gzip_file : hadoop_file:string ‑> (Async.Reader.t ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t

val with_xzip_file : string ‑> f:(Async.Reader.t ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t