pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Define a single `ChartPlotWidget.feed: Feed` for pause/resume

multi_symbol_input
Tyler Goodlet 2022-11-16 13:40:15 -05:00
parent 92c50aa6a7
commit 6986be1b21
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
piker/ui/_chart.py
View File

@ -896,7 +896,7 @@ class ChartPlotWidget(pg.PlotWidget):
# registry of overlay curve names # registry of overlay curve names
self._flows: dict[str, Flow] = {} self._flows: dict[str, Flow] = {}
self._feeds: dict[Symbol, Feed] = {} self.feed: Feed | None = None
self._labels = {} # registry of underlying graphics self._labels = {} # registry of underlying graphics
self._ysticks = {} # registry of underlying graphics self._ysticks = {} # registry of underlying graphics
@ -917,20 +917,18 @@ class ChartPlotWidget(pg.PlotWidget):
self._on_screen: bool = False self._on_screen: bool = False
def resume_all_feeds(self): def resume_all_feeds(self):
... feed = self.feed
# try: if feed:
# for feed in self._feeds.values(): try:
# for flume in feed.flumes.values(): self.linked.godwidget._root_n.start_soon(feed.resume)
# self.linked.godwidget._root_n.start_soon(flume.resume) except RuntimeError:
# except RuntimeError: # TODO: cancel the qtractor runtime here?
# # TODO: cancel the qtractor runtime here? raise
# raise
def pause_all_feeds(self): def pause_all_feeds(self):
... feed = self.feed
# for feed in self._feeds.values(): if feed:
# for flume in feed.flumes.values(): self.linked.godwidget._root_n.start_soon(feed.pause)
# self.linked.godwidget._root_n.start_soon(flume.pause)
@property @property
def view(self) -> ChartView: def view(self) -> ChartView: