From b706cd9d4d2ccf368c739791187640c9b55df52b Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 2 May 2021 14:13:23 -0400 Subject: [PATCH] Cancel scope on stream consumer completion --- tests/test_streaming.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tests/test_streaming.py b/tests/test_streaming.py index 8d8169e..43acb95 100644 --- a/tests/test_streaming.py +++ b/tests/test_streaming.py @@ -338,6 +338,8 @@ async def test_respawn_consumer_task( print("all values streamed, BREAKING") break + cs.cancel() + # TODO: this is justification for a # ``ActorNursery.stream_from_actor()`` helper? await portal.cancel_actor()