seba
/
cw-generator
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

server: use websocket's own broadcast method() 

I hope this will reduce latency. Initial tests looked a bit better but
not great.
This commit is contained in:
Sebastian Lohff 2025-05-11 00:15:31 +02:00
parent 0de9c11fc7
commit 615840ac9f
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
signalsrv/signalsrv.py
View File

@ -4,6 +4,7 @@ import json
import logging import logging
import re import re
from websockets.asyncio.connection import broadcast
from websockets.asyncio.server import serve from websockets.asyncio.server import serve
__VERSION__ = "0.0.1" __VERSION__ = "0.0.1"
@ -175,9 +176,7 @@ class Client:
raise raise
async def _send_to_group(self, group, **kwargs): async def _send_to_group(self, group, **kwargs):
async with asyncio.TaskGroup() as tg: broadcast([c.websocket for c in group], json.dumps(kwargs).encode() + b"\n")
for member in group:
tg.create_task(member._send(ignore_exceptions=True, **kwargs))
async def _send_error(self, msg: str): async def _send_error(self, msg: str):
await self._send(type="error", message=msg) await self._send(type="error", message=msg)