From 2a35541dc53e5f13a13a216896e5606f39c76a5b Mon Sep 17 00:00:00 2001 From: John Smith Date: Sun, 8 Dec 2019 17:55:58 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8D=95=E8=8E=B7write=5Fmessage=E5=BC=82?= =?UTF-8?q?=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- views/chat.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/views/chat.py b/views/chat.py index 746ed9c..b0a0233 100644 --- a/views/chat.py +++ b/views/chat.py @@ -111,7 +111,10 @@ class Room(blivedm.BLiveClient): def send_message(self, cmd, data): body = json.dumps({'cmd': cmd, 'data': data}) for client in self.clients: - client.write_message(body) + try: + client.write_message(body) + except tornado.websocket.WebSocketClosedError: + pass async def _on_receive_danmaku(self, danmaku: blivedm.DanmakuMessage): asyncio.ensure_future(self.__on_receive_danmaku(danmaku)) @@ -312,4 +315,7 @@ class ChatHandler(tornado.websocket.WebSocketHandler): def send_message(self, cmd, data): body = json.dumps({'cmd': cmd, 'data': data}) - self.write_message(body) + try: + self.write_message(body) + except tornado.websocket.WebSocketClosedError: + pass