diff --git a/server/collect.py b/server/collect.py
index 20f9246..a03cbbf 100644
--- a/server/collect.py
+++ b/server/collect.py
@@ -89,12 +89,12 @@ def run(args: argparse.Namespace) -> None:
                     apply_procedural(snapshot)
                     store["records"].append(snapshot)
                     save_store(out, store, args.max_records)
-                    if args.diff and last_broadcast:
+                    if args.diff:
                         payload = jay_diff_full(last_broadcast, snapshot, combine_upd_add=True)
                     else:
                         payload = snapshot
+                    last_broadcast = payload
                     network.broadcast(payload, push_clients, push_lock)
-                    last_broadcast = snapshot
                     log.info("Record #%d saved at %s", len(store["records"]), snapshot["ts"])
                 except KeyboardInterrupt:
                     raise