From 6d9d9ac34b994ec2dc9a3d5d9f81914bc143c3f3 Mon Sep 17 00:00:00 2001 From: Alexander <56935749+alex2211-put@users.noreply.github.com> Date: Mon, 23 Sep 2024 14:50:17 +0300 Subject: [PATCH] Update topic_reader_asyncio.py --- ydb/_topic_reader/topic_reader_asyncio.py | 1 + 1 file changed, 1 insertion(+) diff --git a/ydb/_topic_reader/topic_reader_asyncio.py b/ydb/_topic_reader/topic_reader_asyncio.py index 81c6d9f4..aebaa186 100644 --- a/ydb/_topic_reader/topic_reader_asyncio.py +++ b/ydb/_topic_reader/topic_reader_asyncio.py @@ -433,6 +433,7 @@ async def _read_messages_loop(self): ), ) ) + while True: try: message = await self._stream.receive() # type: StreamReadMessage.FromServer