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.
2 parents aeb5eb3 + 74d22c5 commit 0cf6722Copy full SHA for 0cf6722
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