Merge pull request #34 from Ivashkaization/33-fix-command-hangs-on-cl…

…osing-connection-if-nsqd-socket-is-closed-during-message-sending Catch `writer.wait_closed()` exception to avoid command hanging. #33
list-family · Apr 21, 2021 · ed4424d · ed4424d
2 parents adef6cb + 3545d9a
commit ed4424d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ansq/tcp/connection.py b/ansq/tcp/connection.py
@@ -124,8 +124,8 @@ async def _do_close(
             self._writer.close()
             if sys.version_info >= (3, 7):
                 await self._writer.wait_closed()
-        finally:
-            pass
+        except Exception as e:
+            self.logger.exception(e)
 
         for future, callback in self._cmd_waiters:
             if not future.cancelled():