protocols/sync_struct: disconnection can also cause BrokenPipeError

This commit is contained in:
Sebastien Bourdeauducq 2015-10-20 00:35:02 +08:00
parent da70f8b88c
commit 71d2e3a69f

View File

@ -236,7 +236,7 @@ class Publisher(AsyncioServer):
await writer.drain()
finally:
self._recipients[notifier_name].remove(queue)
except ConnectionResetError:
except (ConnectionResetError, BrokenPipeError):
# subscribers disconnecting are a normal occurence
pass
finally: