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)