YunoHost/yunorunner
1
0
Fork 0
mirror of https://github.com/YunoHost/yunorunner.git synced 2024-09-03 20:05:52 +02:00
Code Issues Projects Releases Packages Wiki Activity

revert the way we remove websockets in a list

Browse source
This commit is contained in:
Kay0u 2021-06-17 16:13:10 +02:00
parent 84df910e20
commit 657810edc3
No known key found for this signature in database
GPG key ID: AAFEEB16CFA2AE2D
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
run.py
View file

@ -470,13 +470,16 @@ async def broadcast(message, channels):
for channel in channels: for channel in channels:
ws_list = subscriptions[channel] ws_list = subscriptions[channel]
dead_ws = []
for ws in ws_list: for ws in ws_list:
try: try:
await ws.send(json.dumps(message, default=datetime_to_epoch_json_converter)) await ws.send(json.dumps(message, default=datetime_to_epoch_json_converter))
except ConnectionClosed: except ConnectionClosed:
ws_list.remove(ws) dead_ws.append(ws)
for to_remove in dead_ws:
ws_list.remove(to_remove)
def subscribe(ws, channel): def subscribe(ws, channel):
subscriptions[channel].append(ws) subscriptions[channel].append(ws)