Method _flush

openkb/watcher.py:50–57

Call the callback with all collected pending paths, then clear.

(self)

            self._timer.start()

    def _flush(self) -> None:
        """Call the callback with all collected pending paths, then clear."""
        with self._lock:
            paths = sorted(self._pending)
            self._pending.clear()
            self._timer = None
        if paths:
            self._callback(paths)

    def _handle_event(self, event) -> None:
        """Add the event's source path to pending if it's a supported file."""