diff --git a/piker/data/__init__.py b/piker/data/__init__.py
index cd0a1183..087928ec 100644
--- a/piker/data/__init__.py
+++ b/piker/data/__init__.py
@@ -35,11 +35,15 @@ from ._source import (
     def_ohlcv_fields,
 )
 from .feed import (
+    Feed,
     open_feed,
 )
+from .flows import Flume
 
 
 __all__ = [
+    'Flume',
+    'Feed',
     'open_feed',
     'ShmArray',
     'iterticks',
diff --git a/piker/data/feed.py b/piker/data/feed.py
index ea7f360b..fcd193da 100644
--- a/piker/data/feed.py
+++ b/piker/data/feed.py
@@ -642,9 +642,12 @@ class Feed(Struct):
     '''
     mods: dict[str, ModuleType] = {}
     portals: dict[ModuleType, tractor.Portal] = {}
-    flumes: dict[str, Flume] = {}
+    flumes: dict[
+        str,  # FQME
+        Flume,
+    ] = {}
     streams: dict[
-        str,
+        str,  # broker name
         trio.abc.ReceiveChannel[dict[str, Any]],
     ] = {}