From 23f191701112bdc13958ff879f52e2b9367f0466 Mon Sep 17 00:00:00 2001 From: Jack Nagy Date: Sat, 22 Aug 2026 18:46:23 +0100 Subject: [PATCH] refactor(mqtt): drop the redundant sleep between OBSERVE registrations _run_session_inner slept 50ms after every subscribe() call. subscribe() opens with self.pace(), which withholds the send until _min_req_interval has passed since the last datagram, and the default rate limit is 5 req/s. The sleep was always shorter than the wait that followed it, so no registration ever left the host at a different time because of it. Noted on #51 and #53. --- mqtt_demo/bridge.py | 1 - 1 file changed, 1 deletion(-) diff --git a/mqtt_demo/bridge.py b/mqtt_demo/bridge.py index 8a8d8a9..9666c24 100644 --- a/mqtt_demo/bridge.py +++ b/mqtt_demo/bridge.py @@ -386,7 +386,6 @@ def _stop_watcher(): def _run_session_inner(self, sess): for path in self.descriptor.observe_paths: sess.subscribe(path) - time.sleep(0.05) # Inline seed so the publish gate opens before the scheduler's # first tick. The scheduler's sweep tier will refresh /device/0