Flush all buffers synchronously. Intended for graceful shutdown.
(self)
| 1033 | self._flush(key) |
| 1034 | |
| 1035 | def flush_all(self) -> None: |
| 1036 | """ |
| 1037 | Flush all buffers synchronously. Intended for graceful shutdown. |
| 1038 | """ |
| 1039 | with self._lock: |
| 1040 | keys = list(self._buffers.keys()) |
| 1041 | for key in keys: |
| 1042 | self._flush(key) |
| 1043 | |
| 1044 | def shutdown(self, timeout: float = 5.0) -> None: |
| 1045 | """ |