radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-02-26 21:53:54 +01:00
Code Issues Activity

man

Browse Source
This commit is contained in:
KubaPro010
2025-12-13 22:26:45 +01:00
parent b76ea0aa03
commit cf441c866c
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/web.html
View File

@@ -166,7 +166,7 @@
renderPlaylist();
} else if(msg.event === "new_track"){
applyTrackState(msg.data);
ws.send(JSON.stringify({action:"get_toplay"}))
ws.send(JSON.stringify({action:"get_toplay"}));
} else if(msg.event === "progress"){
applyProgressState(msg.data);
} else if(msg.event === "toplay") {

11
modules/web.py
View File

@@ -84,15 +84,14 @@ async def broadcast_worker(ws_q: multiprocessing.Queue, clients: set):
"""
loop = asyncio.get_event_loop()
while True:
try: msg = await asyncio.wait_for(loop.run_in_executor(None, ws_q.get), 1.0)
except asyncio.TimeoutError: continue
msg = await loop.run_in_executor(None, ws_q.get)
if msg is None: break
payload = json.dumps(msg)
if clients:
await asyncio.gather(
*[_safe_send(ws, payload, clients) for ws in list(clients)],
return_exceptions=True
)
coros = []
for ws in list(clients):
coros.append(_safe_send(ws, payload, clients))
await asyncio.gather(*coros)
async def _safe_send(ws, payload: str, clients: set):