We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aeb5eb3 commit 74d22c5Copy full SHA for 74d22c5
ydb/_topic_reader/topic_reader_asyncio.py
@@ -192,7 +192,7 @@ async def _connection_loop(self):
192
if self._stream_reader is not None:
193
# noinspection PyBroadException
194
try:
195
- await self._stream_reader.close()
+ await self._stream_reader.close(flush=False)
196
except BaseException:
197
# supress any error on close stream reader
198
pass
0 commit comments