Method get_or_create

nodedb/src/control/array_sync/outbound/merge.rs:252–264

Look up or create the merger for `(session_id, array)`.

(&self, session_id: &str, array: &str)

    /// Look up or create the merger for `(session_id, array)`.
    pub fn get_or_create(&self, session_id: &str, array: &str) -> Arc<MultiShardMerger> {
        let mut mergers = match self.mergers.lock() {
            Ok(g) => g,
            Err(e) => {
                warn!("merger_registry: lock poisoned — returning fresh merger: {e}");
                return Arc::new(MultiShardMerger::new(session_id, array));
            }
        };
        mergers
            .entry((session_id.to_owned(), array.to_owned()))
            .or_insert_with(|| Arc::new(MultiShardMerger::new(session_id, array)))
            .clone()
    }

    /// Remove all mergers for `session_id` (called on disconnect).
    pub fn remove_session(&self, session_id: &str) {