forked from M-Labs/artiq
sync_struct: replace ConnectionError subclasses with ConnectionError (#1318)
This commit is contained in:
parent
30fe624fe5
commit
bbcd1db025
@ -312,8 +312,7 @@ class Publisher(AsyncioServer):
|
|||||||
await writer.drain()
|
await writer.drain()
|
||||||
finally:
|
finally:
|
||||||
self._recipients[notifier_name].remove(queue)
|
self._recipients[notifier_name].remove(queue)
|
||||||
except (ConnectionResetError, ConnectionAbortedError, BrokenPipeError,
|
except (ConnectionError, TimeoutError):
|
||||||
TimeoutError):
|
|
||||||
# subscribers disconnecting are a normal occurrence
|
# subscribers disconnecting are a normal occurrence
|
||||||
pass
|
pass
|
||||||
finally:
|
finally:
|
||||||
|
Loading…
Reference in New Issue
Block a user