w

2026-01-26 13:00:34 +01:00
parent f80061b746
commit 7168a95cbe
1 changed files with 5 additions and 3 deletions
@@ -153,7 +153,9 @@ class JungfrauJochPreview:
            self._socket.setsockopt(zmq.UNSUBSCRIBE, ZMQ_TOPIC_FILTER)

    def _parse_data(self, data):
-        message = cbor2.loads(data, tag_hook=tag_hook)
+        messages = cbor2.loads(data, tag_hook=tag_hook)
        # Parse message to data, call callback with data
-        for cb in self._on_update_callback:
-            cb(message)
+        for message in messages:
+            message = cbor2.loads(message, tag_hook=tag_hook)
+            for cb in self._on_update_callback:
+                cb(message)