set closing future result

Solve deadlock when closing the connection
mosquito · Dec 20, 2024 · f4da0ad · f4da0ad
1 parent 120965c
commit f4da0ad
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/aiormq/connection.py b/aiormq/connection.py
@@ -791,6 +791,7 @@ async def _on_close(
         await asyncio.gather(
             self._reader_task, self._writer_task, return_exceptions=True,
         )
+        self.closing.set_result('done')
 
     @property
     def server_capabilities(self) -> ArgumentsType: