From b6e083e3c0a5e204e9a29dd3274066614672c320 Mon Sep 17 00:00:00 2001
From: BobTheBuidler <70677534+BobTheBuidler@users.noreply.github.com>
Date: Mon, 15 Jul 2024 19:41:57 -0400
Subject: [PATCH] fix: incomplete queue

---
 a_sync/utils/iterators.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/a_sync/utils/iterators.py b/a_sync/utils/iterators.py
index 14b502ab..2755acd1 100644
--- 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: