weyne/dcs-retribution
1
0
Fork 0
mirror of https://github.com/dcs-retribution/dcs-retribution.git synced 2025-11-10 15:41:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update to Python3.11

Browse Source
This commit is contained in:
Raffson
2023-10-15 19:53:24 +02:00
parent 291822b5c8
commit d6ba45a42b
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
game/server/eventstream/routes.py
View File

@@ -1,4 +1,4 @@
from asyncio import wait
from asyncio import wait, create_task
from fastapi import APIRouter, WebSocket
from fastapi.encoders import jsonable_encoder
@@ -17,7 +17,7 @@ class ConnectionManager:
async def shutdown(self) -> None:
futures = []
for connection in self.active_connections:
futures.append(connection.close())
futures.append(create_task(connection.close()))
await wait(futures)
async def connect(self, websocket: WebSocket) -> None:
@@ -30,7 +30,7 @@ class ConnectionManager:
async def broadcast(self, events: GameUpdateEventsJs) -> None:
futures = []
for connection in self.active_connections:
futures.append(connection.send_json(jsonable_encoder(events)))
futures.append(create_task(connection.send_json(jsonable_encoder(events))))
await wait(futures)