Catch ws reset error

This commit is contained in:
Nick Mowen 2023-10-21 20:03:08 -06:00
parent 9fc93c72a0
commit 11110317d9

View File

@ -85,7 +85,11 @@ class WebSocketClient(Communicator): # type: ignore[misc]
logger.debug(f"payload for {topic} wasn't text. Skipping...") logger.debug(f"payload for {topic} wasn't text. Skipping...")
return return
try:
self.websocket_server.manager.broadcast(ws_message) self.websocket_server.manager.broadcast(ws_message)
except ConnectionResetError:
pass
def stop(self) -> None: def stop(self) -> None:
self.websocket_server.manager.close_all() self.websocket_server.manager.close_all()