Module IO.Stream

type 'a t = 'a Async_kernel.Pipe.Reader.t
val map : 'a Async_kernel.Pipe.Reader.t -> ( 'b -> 'c Async_kernel__Deferred1.t ) -> 'd Async_kernel.Pipe.Reader.t
val iter : 'a Async_kernel.Pipe.Reader.t -> ( 'a -> unit Async_kernel__.Deferred.t ) -> unit Async_kernel__.Deferred.t
val close : 'a Async_kernel.Pipe.Reader.t -> unit