WIP table work

Author: tacaswell

bluesky_widgets/examples/ipy_qt_figures.py

@@ -5,15 +5,25 @@
 
 In [1]: %run -m bluesky_widgets.examples.ipy_qt_figures
 """
+import pandas as pd
+
 from bluesky import RunEngine
 from bluesky.plans import scan
 from ophyd.sim import motor, det
 
 from bluesky_widgets.utils.streaming import stream_documents_into_runs
+from bluesky_widgets.models.utils import call_or_eval
 from bluesky_widgets.models.auto_plot_builders import AutoLines
 from bluesky_widgets.qt.figures import QtFigures
 from bluesky_widgets.examples.utils.generate_msgpack_data import get_catalog
 
+from bluesky.callbacks.core import LiveTable
+
+import matplotlib.pyplot as plt
+
+plt.plot(range(5))
+plt.close("all")
+
 model = AutoLines(max_runs=3)
 view = QtFigures(model.figures)
 view.show()
@@ -32,4 +42,35 @@ def plan():
         yield from scan([det], motor, -1, 1, 1 + 2 * i)
 
 
-RE(plan())
+catch = []
+
+
+def test(run):
+    catch.append(run)
+
+    def handle_stream(evt):
+        catch.append(evt)
+        if evt.name != "primary":
+            return
+        count = 0
+        run = evt.run
+        cols = {f"col{j}": k for j, k in enumerate(run.primary.read())}
+
+        def handle_data(evt):
+            nonlocal count
+
+            catch.append(evt)
+            d = call_or_eval(cols, run, ["primary"])
+            df = pd.DataFrame({k: v[count:] for k, v in d.items()})
+            # print(df)
+            count += len(df)
+
+        run.events.new_data.connect(handle_data)
+        lt = LiveTable(list(cols.values()))
+        lt("start", run.metadata["start"])
+        run.events.new_doc.connect(lambda event: lt(event.name, event.doc))
+
+    run.events.new_stream.connect(handle_stream)
+
+
+RE(plan(), stream_documents_into_runs(test))

bluesky_widgets/models/plot_specs.py

@@ -10,7 +10,7 @@
 import uuid as uuid_module
 
 from bluesky_live.event import EmitterGroup, Event
-from ..utils.list import EventedList
+from bluesky_live.list import ListModel as EventedList
 from ..utils.dict_view import UpdateOnlyDict, DictView
 
 
@@ -66,7 +66,41 @@ def __repr__(self):
 
 
 class TableContainer(Container):
-    ...
+    __slots__ = ("_tables",)
+
+
+class Table(BaseSpec):
+    __slots__ = (
+        "_live",
+        "_label",
+        "_parent",
+        "_fields"
+    )
+
+    def __init__(self, *, label, fields, live=True, uuid=None, parent=None):
+        self._label = label
+        self._live = live
+        self._fields = tuple(fields)
+        self.events = EmitterGroup(
+            source=self,
+            label=Event,
+            new_data=Event,
+            completed=Event,
+            style_updated=Event,
+        )
+
+    @property
+    def label(self):
+        return self._label
+
+    @label.setter
+    def label(self, value):
+        self._label = value
+        self.events.label(value=value)
+
+    @property
+    def fields(self, value):
+        return self._fields
 
 
 class Figure(Container):