diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index 7bb0231d..37d7623f 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -876,6 +876,7 @@ async def uniform_rate_send(
         except tractor.RemoteActorError as rme:
             if rme.type is not tractor._exceptions.StreamOverrun:
                 raise
+
             ctx = stream._ctx
             chan = ctx.chan
             log.warning(
@@ -892,6 +893,7 @@ async def uniform_rate_send(
             trio.ClosedResourceError,
             trio.BrokenResourceError,
             ConnectionResetError,
+            trio.EndOfChannel,
         ):
             # if the feed consumer goes down then drop
             # out of this rate limiter