Unbuffered.
This commit is contained in:
parent
10c7232a8f
commit
88749ce05c
@ -159,8 +159,10 @@ class RPCView(BaseView):
|
|||||||
break
|
break
|
||||||
elif msg.type == web.WSMsgType.ERROR:
|
elif msg.type == web.WSMsgType.ERROR:
|
||||||
print(f"WebSocket exception {ws.exception()}")
|
print(f"WebSocket exception {ws.exception()}")
|
||||||
await self.services.socket.delete(ws)
|
pass
|
||||||
|
#await self.services.socket.delete(ws)
|
||||||
elif msg.type == web.WSMsgType.CLOSE:
|
elif msg.type == web.WSMsgType.CLOSE:
|
||||||
await self.services.socket.delete(ws)
|
pass
|
||||||
|
#await self.services.socket.delete(ws)
|
||||||
print("WebSocket connection closed")
|
print("WebSocket connection closed")
|
||||||
return ws
|
return ws
|
||||||
|
Loading…
Reference in New Issue
Block a user