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