sync_struct: handle TimeoutError as subscriber disconnection. Closes #1215

This commit is contained in:
Sebastien Bourdeauducq 2018-12-13 06:58:54 +08:00
parent b1ea02ddf0
commit 371dda4a16

View File

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