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