If a sample stream is already ded, just warn

2022-04-22 14:06:48 -04:00 · 2022-04-22 14:06:48 -04:00 · 04c12a756c
parent cde23361a4
commit 04c12a756c
1 changed files with 6 additions and 1 deletions
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@ -160,7 +160,12 @@ async def broadcast(
            log.error(
                f'{stream._ctx.chan.uid} dropped connection'
            )
+            try:
                subs.remove(stream)
+            except ValueError:
+                log.warning(
+                    f'{stream._ctx.chan.uid} sub already removed!?'
+                )


@tractor.context