More tolerance for "stream-ended-early" conditions in quote throttler

2022-04-27 17:17:04 -04:00 · 2022-04-27 17:17:04 -04:00 · 19205d57a1
parent e4158dce01
commit 19205d57a1
1 changed files with 6 additions and 1 deletions
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@ -385,7 +385,12 @@ async def uniform_rate_send(

        if left_to_sleep > 0:
            with trio.move_on_after(left_to_sleep) as cs:
+                try:
                    sym, last_quote = await quote_stream.receive()
+                except trio.EndOfChannel:
+                    log.exception(f"feed for {stream} ended?")
+                    break
+
                diff = time.time() - last_send

                if not first_quote: