Method write

nodedb/src/event/cdc/registry.rs:93–95

(&self)

    }

    fn write(&self) -> std::sync::RwLockWriteGuard<'_, Inner> {
        self.inner.write().unwrap_or_else(|p| p.into_inner())
    }

    /// Register a new change stream.
    pub fn register(&self, def: ChangeStreamDef) {