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