Io.Stream
type 'a t
= 'a Lwt_stream.t * (unit -> unit)
type +'a io
val map : 'a t -> ('a -> 'b io) -> 'b t
val iter : 'a t -> ('a -> unit io) -> unit io
val close : 'a t -> unit