From 36da350abc8b5a50fb733c31de9a125af2d87e73 Mon Sep 17 00:00:00 2001 From: appel_c Date: Mon, 26 Jan 2026 13:02:29 +0100 Subject: [PATCH] w --- .../devices/jungfraujoch/jungfraujoch_preview.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py b/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py index 2ec75fb..9d31d2b 100644 --- a/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py +++ b/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)