Inf_pipe.Reader
type 'a t = private 'a Async.Pipe.Reader.t
val create : 'a Async.Pipe.Reader.t -> 'a t