sig type 'a t = 'Lwt_stream.t end