Method remove

nodedb/src/event/cdc/registry.rs:62–75

(&mut self, tenant_id: u64, name: &str)

    }

    fn remove(&mut self, tenant_id: u64, name: &str) -> bool {
        let key_name = (tenant_id, name.to_string());
        let Some(prev) = self.by_name.remove(&key_name) else {
            return false;
        };
        let key_coll = (prev.tenant_id, prev.collection.clone());
        if let Some(bucket) = self.by_collection.get_mut(&key_coll) {
            bucket.retain(|d| d.name != prev.name);
            if bucket.is_empty() {
                self.by_collection.remove(&key_coll);
            }
        }
        true
    }
}

pub struct StreamRegistry {