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