bec/bec_widgets
0
0
Fork 0
mirror of https://github.com/bec-project/bec_widgets.git synced 2025-07-13 19:21:50 +02:00
Code Activity

wip debug dispatcher

Browse Source
This commit is contained in:
appel_c
2025-04-15 13:51:56 +02:00
committed by perl_d
parent ffc3aebffd
commit 120303b8db
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
bec_widgets/utils/bec_dispatcher.py
View File

@ -27,7 +27,7 @@ class QtThreadSafeCallback(QObject):
def __init__(self, cb):
super().__init__()
self.topics = None
self.cb = cb
self.cb_signal.connect(self.cb)
@ -38,6 +38,7 @@ class QtThreadSafeCallback(QObject):
return id(self.cb)
def __call__(self, msg_content, metadata):
logger.info(f"Received message for topic {self.topics}")
self.cb_signal.emit(msg_content, metadata)
@ -147,6 +148,7 @@ class BECDispatcher:
topics (EndpointInfo | str | list): A topic or list of topics that can typically be acquired via bec_lib.MessageEndpoints
"""
slot = QtThreadSafeCallback(slot)
slot.topics = topics
self.client.connector.register(topics, cb=slot, **kwargs)
topics_str, _ = self.client.connector._convert_endpointinfo(topics)
self._slots[slot].update(set(topics_str))