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)