diff --git a/modules/web.html b/modules/web.html
index 5801987..51af747 100644
--- a/modules/web.html
+++ b/modules/web.html
@@ -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") {
diff --git a/modules/web.py b/modules/web.py
index 59641d2..4144c40 100644
--- a/modules/web.py
+++ b/modules/web.py
@@ -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):