Method get_buffer

nodedb/src/event/cdc/router.rs:247–251

Get a buffer for a stream (if it exists). Used by consumers to poll events.

(&self, tenant_id: u64, stream_name: &str)

    /// Get a buffer for a stream (if it exists). Used by consumers to poll events.
    pub fn get_buffer(&self, tenant_id: u64, stream_name: &str) -> Option<Arc<StreamBuffer>> {
        let key = (tenant_id, stream_name.to_string());
        let buffers = self.buffers.read().unwrap_or_else(|p| p.into_inner());
        buffers.get(&key).cloned()
    }

    /// Remove a buffer when a stream is dropped.
    pub fn remove_buffer(&self, tenant_id: u64, stream_name: &str) {