Merge pull request #9 from SomberNight/faster_tg_cancellation

TaskGroup: faster cancellation
kyuupichan · Dec 9, 2018 · 294e9bb · 294e9bb
2 parents 9b701b2 + 9403e11
commit 294e9bb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/aiorpcx/curio.py b/aiorpcx/curio.py
@@ -202,8 +202,10 @@ def errored(task):
     async def cancel_remaining(self):
         '''Cancel all remaining tasks.'''
         self._closed = True
-        for task in list(self._pending):
+        task_list = list(self._pending)
+        for task in task_list:
             task.cancel()
+        for task in task_list:
             with suppress(CancelledError):
                 await task