let of_stream e = e /@ (fun x -> x, ()) |! LMap.of_stream