Module Inf_pipe.T

module Reader : sig ... end
val read : ?consumer:Async.Pipe.Consumer.t -> 'a Async.Pipe.Reader.t -> 'b Async_kernel__Deferred.t
val read_now : ?consumer:Async.Pipe.Consumer.t -> 'a Async.Pipe.Reader.t -> [> `Nothing_available | `Ok of 'b ]
val read_exactly : ?consumer:Async.Pipe.Consumer.t -> 'a Async.Pipe.Reader.t -> num_values:int -> 'a Core.Queue.t Async_kernel__Deferred.t
val to_pipe : 'a Async.Pipe.Reader.t -> 'a Async.Pipe.Reader.t
val interleave : 'a Async.Pipe.Reader.t list -> 'b Reader.t
val unfold : init:'s -> f:('s0 -> ('a * 's1) Async_kernel__Deferred.t) -> 'a0 Reader.t
val map : 'a Async.Pipe.Reader.t -> f:('a -> 'b) -> 'b Async.Pipe.Reader.t
val filter_map : ?max_queue_length:int -> 'a Async.Pipe.Reader.t -> f:('a -> 'b option) -> 'b Async.Pipe.Reader.t