w

csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py

@@ -152,10 +152,11 @@ class JungfrauJochPreview:
             # Unsubscribe from the topic
             self._socket.setsockopt(zmq.UNSUBSCRIBE, ZMQ_TOPIC_FILTER)
 
-    def _parse_data(self, data):
-        messages = cbor2.loads(data, tag_hook=tag_hook)
-        # Parse message to data, call callback with data
-        for message in messages:
-            message = cbor2.loads(message, tag_hook=tag_hook)
-            for cb in self._on_update_callback:
-                cb(message)
+    def _parse_data(self, bytes_list: list[bytes]):
+        for byte_msg in bytes_list:
+            messages = cbor2.loads(byte_msg, tag_hook=tag_hook)
+            # Parse message to data, call callback with data
+            for message in messages:
+                message = cbor2.loads(message, tag_hook=tag_hook)
+                for cb in self._on_update_callback:
+                    cb(message)