package async_extended
Legend:
Library
Module
Module type
Parameter
Class
Class type
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