Method close

nodedb-cluster/src/applied_watcher/watcher.rs:77–83

Mark this watcher closed and wake every waiter with [`WaitOutcome::GroupGone`]. Idempotent.

(&self)

    /// Mark this watcher closed and wake every waiter with
    /// [`WaitOutcome::GroupGone`]. Idempotent.
    pub fn close(&self) {
        let mut guard = self.state.lock().unwrap_or_else(|p| p.into_inner());
        if !guard.closed {
            guard.closed = true;
            self.cv.notify_all();
        }
    }

    /// Block until the watermark reaches `target`, the timeout elapses,
    /// or the watcher is closed.