Method remove

nodedb-cluster/src/applied_watcher/registry.rs:70–78

Remove the watcher for `group_id`. Wakes outstanding waiters with [`WaitOutcome::GroupGone`]. Idempotent.

(&self, group_id: u64)

    /// Remove the watcher for `group_id`. Wakes outstanding waiters
    /// with [`WaitOutcome::GroupGone`]. Idempotent.
    pub fn remove(&self, group_id: u64) {
        let removed = {
            let mut w = self.inner.write().unwrap_or_else(|p| p.into_inner());
            w.remove(&group_id)
        };
        if let Some(w) = removed {
            w.close();
        }
    }

    /// Block until `group_id`'s applied watermark reaches `target`,
    /// the timeout elapses, or the group is removed. Lazily creates