import os
import sys
import json
-from websockets import (WebSocketServerProtocol, ConnectionClosedOK,
- ConnectionClosedError, serve)
+from websockets import WebSocketServerProtocol, ConnectionClosed, serve
from websockets.http import Headers
from http import HTTPStatus
message = {'sender': self._name}
message.update(original_message)
await self._bus.send(message)
- except (ConnectionClosedOK, ConnectionClosedError):
+ except ConnectionClosed:
pass
await self._bus.send({'sender': self._name,
'event': 'connection closed'})