diff --git a/game/server/eventstream/routes.py b/game/server/eventstream/routes.py index e1210bfd..929a0b1b 100644 --- a/game/server/eventstream/routes.py +++ b/game/server/eventstream/routes.py @@ -1,3 +1,4 @@ +import asyncio from asyncio import wait from fastapi import APIRouter, WebSocket @@ -30,7 +31,9 @@ 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( + asyncio.create_task(connection.send_json(jsonable_encoder(events))) + ) await wait(futures)