Unbuffered.
This commit is contained in:
parent
8f502af84e
commit
10c7232a8f
@ -148,7 +148,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)
|
print(msg,flush=True)
|
||||||
if msg.type == web.WSMsgType.TEXT:
|
if msg.type == web.WSMsgType.TEXT:
|
||||||
try:
|
try:
|
||||||
await rpc(msg.json())
|
await rpc(msg.json())
|
||||||
|
Loading…
Reference in New Issue
Block a user