From 9c3f8ff0504f3a0737a91c9540d218d31807aa31 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Wed, 14 Apr 2021 11:01:43 -0400 Subject: [PATCH] Only do context unsubs in main feed bus path --- piker/data/_sampling.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py index 40951697..c0f47d8e 100644 --- a/piker/data/_sampling.py +++ b/piker/data/_sampling.py @@ -236,5 +236,8 @@ async def sample_and_broadcast( trio.BrokenResourceError, trio.ClosedResourceError ): - subs.remove(ctx) + # XXX: do we need to deregister here + # if it's done in the fee bus code? + # so far seems like no since this should all + # be single-threaded. log.error(f'{ctx.chan.uid} dropped connection')