github-repos/blivechat
1
0
Fork 0
mirror of https://github.com/xfgryujk/blivechat.git synced 2025-03-23 08:10:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

捕获write_message异常

Browse Source
This commit is contained in:
John Smith 2019-12-08 17:55:58 +08:00
parent a927282e77
commit 2a35541dc5
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
views/chat.py
View File

@ -111,7 +111,10 @@ class Room(blivedm.BLiveClient):
def send_message(self, cmd, data): def send_message(self, cmd, data):
body = json.dumps({'cmd': cmd, 'data': data}) body = json.dumps({'cmd': cmd, 'data': data})
for client in self.clients: 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): async def _on_receive_danmaku(self, danmaku: blivedm.DanmakuMessage):
asyncio.ensure_future(self.__on_receive_danmaku(danmaku)) asyncio.ensure_future(self.__on_receive_danmaku(danmaku))
@ -312,4 +315,7 @@ class ChatHandler(tornado.websocket.WebSocketHandler):
def send_message(self, cmd, data): def send_message(self, cmd, data):
body = json.dumps({'cmd': cmd, 'data': data}) body = json.dumps({'cmd': cmd, 'data': data})
self.write_message(body) try:
self.write_message(body)
except tornado.websocket.WebSocketClosedError:
pass