always close the write handle
This commit is contained in:
parent
ff2985cc80
commit
68d7328918
1 changed files with 4 additions and 0 deletions
|
@ -168,6 +168,10 @@ class BlobExchangeClientProtocol(asyncio.Protocol):
|
||||||
except asyncio.CancelledError:
|
except asyncio.CancelledError:
|
||||||
self.close()
|
self.close()
|
||||||
raise
|
raise
|
||||||
|
finally:
|
||||||
|
if self.writer and not self.writer.closed():
|
||||||
|
self.writer.close_handle()
|
||||||
|
self.writer = None
|
||||||
|
|
||||||
def connection_made(self, transport: asyncio.Transport):
|
def connection_made(self, transport: asyncio.Transport):
|
||||||
self.transport = transport
|
self.transport = transport
|
||||||
|
|
Loading…
Reference in a new issue