Update topic_reader_asyncio.py

alex2211-put · web-flow · commit 6d9d9ac34b99 · 2024-09-23T14:50:17.000+03:00
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -433,6 +433,7 @@ async def _read_messages_loop(self):`
`433`	`433`	`),`
`434`	`434`	`)`
`435`	`435`	`)`
	`436`	`+`
`436`	`437`	`while True:`
`437`	`438`	`try:`
`438`	`439`	`message = await self._stream.receive() # type: StreamReadMessage.FromServer`