diff --git a/pyproject.toml b/pyproject.toml
index ad1964a..efa1f81 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -10,9 +10,9 @@ requires-python = ">=3.10"
 dynamic = ["version"]
 dependencies = [
   "array-api-compat>=1.11.0",
-  "ezmsg>=3.7.3",
-  "ezmsg-baseproc>=1.6.0",
-  "ezmsg-sigproc>=2.19.0",
+  "ezmsg>=3.9.0",
+  "ezmsg-baseproc>=1.6.1",
+  "ezmsg-sigproc>=2.20.2",
   "ezmsg-event>=0.8.0",
   "numpy>=1.26.0",
   "sparse>=0.17.0",
@@ -26,7 +26,7 @@ dev = [
   "typer>=0.20.0",
   "scipy-stubs>=1.15.3.0",
   "ezmsg-peripheraldevice>=0.3.0",
-  "ezmsg-lsl>=1.5.1",
+  "ezmsg-lsl>=1.6.0",
 ]
 lint = [
   "ruff",
diff --git a/src/ezmsg/simbiophys/dnss/synth.py b/src/ezmsg/simbiophys/dnss/synth.py
index 46cc33f..9f1690a 100644
--- a/src/ezmsg/simbiophys/dnss/synth.py
+++ b/src/ezmsg/simbiophys/dnss/synth.py
@@ -69,7 +69,7 @@ class DNSSSynth(ez.Collection):
 
     SETTINGS = DNSSSynthSettings
 
-    OUTPUT_SIGNAL = ez.OutputStream(AxisArray)
+    OUTPUT_SIGNAL = ez.OutputTopic(AxisArray)
 
     # Clock produces timestamps at the block rate
     CLOCK = Clock()
diff --git a/src/ezmsg/simbiophys/eeg.py b/src/ezmsg/simbiophys/eeg.py
index be7bc8a..a8088ed 100644
--- a/src/ezmsg/simbiophys/eeg.py
+++ b/src/ezmsg/simbiophys/eeg.py
@@ -41,7 +41,7 @@ class EEGSynth(ez.Collection):
 
     SETTINGS = EEGSynthSettings
 
-    OUTPUT_SIGNAL = ez.OutputStream(AxisArray)
+    OUTPUT_SIGNAL = ez.OutputTopic(AxisArray)
 
     CLOCK = Clock()
     NOISE = WhiteNoise()
diff --git a/src/ezmsg/simbiophys/system/velocity2ecephys.py b/src/ezmsg/simbiophys/system/velocity2ecephys.py
index 424ce9e..947c20c 100644
--- a/src/ezmsg/simbiophys/system/velocity2ecephys.py
+++ b/src/ezmsg/simbiophys/system/velocity2ecephys.py
@@ -75,12 +75,12 @@ class VelocityEncoder(ez.Collection):
     SETTINGS = VelocityEncoderSettings
 
     # Velocity inputs (via mouse / gamepad system, or via task parsing system)
-    INPUT_SIGNAL = ez.InputStream(AxisArray)
+    INPUT_SIGNAL = ez.InputTopic(AxisArray)
     COORDS = CoordinateSpaces()  # Cartesian to polar (done once, shared by both branches)
     SPIKES = Velocity2Spike()
     LFP = Velocity2LFP()
     ADD = Add()  # Add colored noise and waveforms
-    OUTPUT_SIGNAL = ez.OutputStream(AxisArray)
+    OUTPUT_SIGNAL = ez.OutputTopic(AxisArray)
 
     def configure(self) -> None:
         self.COORDS.apply_settings(CoordinateSpacesSettings(mode=CoordinateMode.CART2POL, axis="ch"))
diff --git a/src/ezmsg/simbiophys/system/velocity2lfp.py b/src/ezmsg/simbiophys/system/velocity2lfp.py
index 97ac886..0dca076 100644
--- a/src/ezmsg/simbiophys/system/velocity2lfp.py
+++ b/src/ezmsg/simbiophys/system/velocity2lfp.py
@@ -79,12 +79,12 @@ class Velocity2LFP(ez.Collection):
     SETTINGS = Velocity2LFPSettings
 
     # Polar velocity inputs (magnitude, angle)
-    INPUT_SIGNAL = ez.InputStream(AxisArray)
+    INPUT_SIGNAL = ez.InputTopic(AxisArray)
     BETA_ENCODER = CosineEncoderUnit()
     CLIP_BETA = Clip()
     PINK_NOISE = DynamicColoredNoiseUnit()
     MIX_NOISE = AffineTransform()  # Project n_lfp_sources to output_ch sensors
-    OUTPUT_SIGNAL = ez.OutputStream(AxisArray)
+    OUTPUT_SIGNAL = ez.OutputTopic(AxisArray)
 
     def configure(self) -> None:
         # Input is polar coords: [magnitude, angle]
diff --git a/src/ezmsg/simbiophys/system/velocity2spike.py b/src/ezmsg/simbiophys/system/velocity2spike.py
index b5a434e..b428aec 100644
--- a/src/ezmsg/simbiophys/system/velocity2spike.py
+++ b/src/ezmsg/simbiophys/system/velocity2spike.py
@@ -77,12 +77,12 @@ class Velocity2Spike(ez.Collection):
     SETTINGS = Velocity2SpikeSettings
 
     # Polar velocity inputs (magnitude, angle)
-    INPUT_SIGNAL = ez.InputStream(AxisArray)
+    INPUT_SIGNAL = ez.InputTopic(AxisArray)
     RATE_ENCODER = CosineEncoderUnit()
     CLIP_RATE = Clip()
     SPIKE_EVENT = PoissonEventUnit()
     WAVEFORMS = SparseKernelInserterUnit()
-    OUTPUT_SIGNAL = ez.OutputStream(AxisArray)
+    OUTPUT_SIGNAL = ez.OutputTopic(AxisArray)
 
     def configure(self) -> None:
         self.RATE_ENCODER.apply_settings(