Enable multi-dimensional plotting

src/napari_tiled_browser/models/tiled_subscriber.py

@@ -0,0 +1,48 @@
+from qtpy.QtCore import QObject, QRunnable, Signal
+
+
+class TiledSubscriberSignals(QObject):
+    finished = Signal()
+    results = Signal(object)
+
+
+class TiledSubscriber(QRunnable):
+    def __init__(
+        self,
+        *,
+        client,
+        node_path_parts,
+        **kwargs,
+    ):
+        super().__init__()
+        self.signals = TiledSubscriberSignals()
+        self.client = client
+        self.node_path_parts = node_path_parts
+
+    def run(self):
+        catalog_sub = self.client.subscribe()
+        catalog_sub.child_created.add_callback(on_new_child)
+        catalog_sub.start()
+
+
+def on_new_child(update):
+    "A new child node has been created in a container."
+    child = update.child()
+    print(child)
+    sub = child.subscribe()
+    # Is the child also a container?
+    if child.structure_family == "container":
+        # Recursively subscribe to the children of this new container.
+        sub.child_created.add_callback(on_new_child)
+    else:
+        # Subscribe to data updates (i.e. appended table rows or array slices).
+        sub.new_data.add_callback(on_new_data)
+        # Launch the subscription.
+        # Ask the server to replay from the very first update, if we already
+        # missed some.
+    sub.start_in_thread(1)
+
+
+def on_new_data(update):
+    "Data has been updated (maybe appended) to an array or table."
+    print(update.data())

src/napari_tiled_browser/qt/tiled_widget.py

@@ -35,6 +35,7 @@
 
 from napari_tiled_browser.models.tiled_selector import TiledSelector
 from napari_tiled_browser.models.tiled_worker import TiledWorker
+from napari_tiled_browser.models.tiled_subscriber import TiledSubscriber
 from napari_tiled_browser.qt.tiled_search import QTiledSearchWidget
 
 _logger = logging.getLogger(__name__)
@@ -248,6 +249,13 @@ def fetch_table_data(self):
         runnable.signals.results.connect(self.populate_table)
         self.thread_pool.start(runnable)
 
+    def subscribe_to_table_data(self):
+        runnable = TiledSubscriber(
+            client=self.model.client,
+            node_path_parts=self.model.node_path_parts,
+        )
+        self.thread_pool.start(runnable)
+
     def populate_table(self, results):
         _logger.debug("QTiledBrowser.populate_table()...")
         original_state = {}