diff --git a/libp2p/network/connection/raw_connection.py b/libp2p/network/connection/raw_connection.py index 4f01b124..bbc41b27 100644 --- a/libp2p/network/connection/raw_connection.py +++ b/libp2p/network/connection/raw_connection.py @@ -55,4 +55,8 @@ class RawConnection(IRawConnection): self.writer.close() if sys.version_info < (3, 7): return - await self.writer.wait_closed() + try: + await self.writer.wait_closed() + # In case the connection is already reset. + except (ConnectionResetError, RawConnError): + return