diff --git a/src/main/frontend/components/rtc/flows.cljs b/src/main/frontend/components/rtc/flows.cljs index 804cc3107..c4ff91d10 100644 --- a/src/main/frontend/components/rtc/flows.cljs +++ b/src/main/frontend/components/rtc/flows.cljs @@ -47,10 +47,11 @@ [user-uuid {:user-info (user-uuid->user user-uuid) :updates - (take-while - (fn [[inst _]] (> inst mins-ago)) + (sequence + (comp (take-while (fn [[inst _]] (> inst mins-ago))) + (dedupe)) (concat (get-in latest-updates [graph-uuid user-uuid]) - (get-in @*buffer [graph-uuid user-uuid])))}])) + (get-in @*buffer [graph-uuid user-uuid :updates])))}])) latest-keys)}] (swap! *buffer merge new-map) @*buffer))))