Flush the buffer contents out to a chunk.
(self, force: bool = False)
| 1295 | self._position += len(data) |
| 1296 | |
| 1297 | async def _flush_buffer(self, force: bool = False) -> None: |
| 1298 | """Flush the buffer contents out to a chunk.""" |
| 1299 | await self._flush_data(self._buffer.getvalue(), force=force) |
| 1300 | self._buffer.close() |
| 1301 | self._buffer = io.BytesIO() |
| 1302 | |
| 1303 | async def _flush(self) -> Any: |
| 1304 | """Flush the file to the database.""" |
no test coverage detected