fix: incomplete queue

BobTheBuidler · Jul 15, 2024 · b6e083e · b6e083e
1 parent 1973ced
commit b6e083e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/a_sync/utils/iterators.py b/a_sync/utils/iterators.py
@@ -139,6 +139,7 @@ def _as_yielded_done_callback(t: asyncio.Task) -> None:
             queue.task_done()
             if isinstance(item, _Done):
                 assert queue.empty()
+                await task
                 del task
                 del queue
                 if item._exc: