Up

Module With_pipe

Signature

type t = Message.t Async.Std.Pipe.Reader.t

val t_of_fd : Async.Std.Fd.t -> t Async.Std.Deferred.t

val t_of_file : string -> t Async.Std.Deferred.t

val of_string : string -> t Async.Std.Deferred.t

val iter_string : t -> f:(string -> unit Async.Std.Deferred.t) -> unit Async.Std.Deferred.t