diff --git a/hauptbahnhof/core/ws.py b/hauptbahnhof/core/ws.py index a5810cea5134491354bbb4c1899437b4d02f2066..80f0c68d609da075fcef2727c1f645786668bc26 100644 --- a/hauptbahnhof/core/ws.py +++ b/hauptbahnhof/core/ws.py @@ -85,7 +85,7 @@ class WebSocket: async def send_update(self, msg: Dict): encoded_msg = json.dumps(msg) - await asyncio.wait([conn.send(encoded_msg) for conn in self.connections]) + await asyncio.gather(*[conn.send(encoded_msg) for conn in self.connections]) def _refresh_cache(self): for token in list(self.cache.keys()):