diff --git a/app/chat/websocket.py b/app/chat/websocket.py index a3f76e2..b549d60 100644 --- a/app/chat/websocket.py +++ b/app/chat/websocket.py @@ -167,7 +167,7 @@ class PollingManager: self.waiters[chat_id].append(future) try: await future - message = self.messages[0] + message = self.messages[chat_id][0] return message except asyncio.CancelledError: self.waiters[chat_id].remove(future)