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 5d94c17 commit 778229eCopy full SHA for 778229e
ydb/_topic_reader/topic_reader_asyncio.py
@@ -120,14 +120,6 @@ async def commit_with_ack(
120
waiter = self._reconnector.commit(batch)
121
await waiter.future
122
123
- async def flush(self):
124
- """
125
- force send all commit messages from internal buffers to server and wait acks for all of them.
126
-
127
- use asyncio.wait_for for wait with timeout.
128
129
- await self._reconnector.flush()
130
131
async def close(self, flush: bool = True):
132
if self._closed:
133
raise TopicReaderClosedError()
0 commit comments