Cancel scope on stream consumer completion

2021-05-02 14:13:23 -04:00 · 2021-05-02 14:13:23 -04:00 · c6e52b0387
parent f792aa06b5
commit c6e52b0387
1 changed files with 2 additions and 0 deletions
--- 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()