Schedule queue after publish

pyscript · Jan 24, 2024 · b21776d · b21776d
1 parent cb17ba8
commit b21776d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ltk/pubsub.py b/ltk/pubsub.py
@@ -101,6 +101,7 @@ def publish(self, sender, receiver, topic, data):
         if show_publish:
             _logger.info(f"[Pubsub] {json.dumps(['publish', sender, receiver, topic, str(data)[:32]])}")
         self.process_queue()
+        schedule(self.process_queue, 100)
 
     def subscribe(self, name, topic, handler):
         self.subscribers.append([name, topic, handler])