diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index 8bc677cf..466ef0e7 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -168,7 +168,12 @@ async def broadcast(
             log.error(
                 f'{stream._ctx.chan.uid} dropped connection'
             )
-            subs.remove(stream)
+            try:
+                subs.remove(stream)
+            except ValueError:
+                log.warning(
+                    f'{stream._ctx.chan.uid} sub already removed!?'
+                )
 
 
 @tractor.context