diff --git a/server/reflector/ws_manager.py b/server/reflector/ws_manager.py
index a1f620c4..83201ce1 100644
--- a/server/reflector/ws_manager.py
+++ b/server/reflector/ws_manager.py
@@ -99,7 +99,8 @@ class WebsocketManager:
     async def _pubsub_data_reader(self, pubsub_subscriber):
         while True:
             message = await pubsub_subscriber.get_message(
-                ignore_subscribe_messages=True
+                ignore_subscribe_messages=True,
+                timeout=1.0,
             )
             if message is not None:
                 room_id = message["channel"].decode("utf-8")