Unbuffered.
This commit is contained in:
@@ -144,6 +144,7 @@ class RPCView(BaseView):
|
|||||||
print("Subscribed for: ", subscription["label"],flush=True)
|
print("Subscribed for: ", subscription["label"],flush=True)
|
||||||
rpc = RPCView.RPCApi(self,ws)
|
rpc = RPCView.RPCApi(self,ws)
|
||||||
async for msg in ws:
|
async for msg in ws:
|
||||||
|
print(msg)
|
||||||
if msg.type == web.WSMsgType.TEXT:
|
if msg.type == web.WSMsgType.TEXT:
|
||||||
await rpc(msg.json())
|
await rpc(msg.json())
|
||||||
elif msg.type == web.WSMsgType.ERROR:
|
elif msg.type == web.WSMsgType.ERROR:
|
||||||
|
|||||||
Reference in New Issue
Block a user