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