type t
= Message.t Async.Pipe.Reader.t
val t_of_fd : Async.Fd.t ‑> t Async.Deferred.t
val t_of_file : string ‑> t Async.Deferred.t
val of_string : string ‑> t Async.Deferred.t
val iter_string : t ‑> f:(string ‑> unit Async.Deferred.t) ‑> unit Async.Deferred.t