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

refactor: project cleaned up

Browse Source
This commit is contained in:
wyzula-jan
2023-09-07 15:29:49 +02:00
parent bfef71382e
commit 7d996ec8e7
1 changed files with 4 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
bec_widgets/examples/mca_readout/mca_plot.py
View File

@ -37,7 +37,7 @@ class StreamApp(QWidget):
self.stream_consumer = connector.stream_consumer( self.stream_consumer = connector.stream_consumer(
topics=MessageEndpoints.device_async_readback(scanID="ScanID1", device="mca"), topics=MessageEndpoints.device_async_readback(scanID="ScanID1", device="mca"),
cb=self._stremer_cb, cb=self._streamer_cb,
parent=self, parent=self,
) )
@ -52,15 +52,8 @@ class StreamApp(QWidget):
def plot_new(self): def plot_new(self):
self.image_item.setImage(self.data) self.image_item.setImage(self.data)
@pyqtSlot(dict, dict)
def get_stream(self, msg, metadata):
print(msg)
print(metadata)
# def connect_stream_slot(self, slot, topic):
@staticmethod @staticmethod
def _stremer_cb(msg, *, parent, **_kwargs) -> None: def _streamer_cb(msg, *, parent, **_kwargs) -> None:
msgMCS = BECMessage.DeviceMessage.loads(msg.value) msgMCS = BECMessage.DeviceMessage.loads(msg.value)
row = msgMCS.content["signals"]["mca1"] row = msgMCS.content["signals"]["mca1"]
@ -75,39 +68,16 @@ class StreamApp(QWidget):
parent.data = row parent.data = row
parent.image_item.clear() parent.image_item.clear()
# print(f"metadata: {metadata}")
# add row vertically to data
parent.data = np.vstack((parent.data, row)) parent.data = np.vstack((parent.data, row))
parent.update_plot.emit() parent.update_plot.emit()
# print(f"msg: {msgMCS}")
# print(f"row: {row}")
if __name__ == "__main__": if __name__ == "__main__":
from bec_widgets.bec_dispatcher import bec_dispatcher
# BECclient global variables
# client = bec_dispatcher.client
# client.start()
#
# dev = client.device_manager.devices
# scans = client.scans
# queue = client.queue
connector = RedisConnector("localhost:6379") connector = RedisConnector("localhost:6379")
app = QApplication([]) app = QApplication([])
progressApp = StreamApp() streamApp = StreamApp()
# bec_dispatcher.connect_slot( streamApp.show()
# slot=progressApp.get_stream,
# topic=MessageEndpoints.device_async_readback(scanID="ScanID1", device="mca"),
# )
# window = ProgressApp()
# window.show()
progressApp.show()
app.exec_() app.exec_()