Method remove

src/watchdog/utils/delayed_queue.py:68–77

Remove and return the first items for which predicate is True, ignoring delay.

(self, predicate: Callable[[T], bool])

                    return head

    def remove(self, predicate: Callable[[T], bool]) -> T | None:
        """Remove and return the first items for which predicate is True,
        ignoring delay.
        """
        with self._lock:
            for i, (elem, *_) in enumerate(self._queue):
                if predicate(elem):
                    del self._queue[i]
                    return elem
        return None