Unbuffered.

Browse Source
This commit is contained in:
retoor 2025-01-31 12:38:58 +01:00
parent c6f4393166
commit 5fd03efc30
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/snek/view/rpc.py
View File

@ -141,7 +141,7 @@ class RPCView(BaseView):
#await self.services.socket.add(ws) #await self.services.socket.add(ws)
#async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False): #async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False):
#await self.services.socket.subscribe(ws,subscription["channel_uid"]) #await self.services.socket.subscribe(ws,subscription["channel_uid"])
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)