From 7168a95cbecadbf6fa83c7562e134514689d3fc9 Mon Sep 17 00:00:00 2001 From: appel_c Date: Mon, 26 Jan 2026 13:00:34 +0100 Subject: [PATCH] w --- csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py b/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py index ed439ed..2ec75fb 100644 --- a/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py +++ b/csaxs_bec/devices/jungfraujoch/jungfraujoch_preview.py @@ -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)