Method get

nodedb/src/control/array_sync/outbound/subscriber_state.rs:145–149

Get the current cursor for `(session_id, array_name)`, if any.

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

    /// Get the current cursor for `(session_id, array_name)`, if any.
    pub fn get(&self, session_id: &str, array_name: &str) -> Option<ArraySubscriberState> {
        let map = self.inner.read().unwrap_or_else(|p| p.into_inner());
        map.get(&(session_id.to_string(), array_name.to_string()))
            .cloned()
    }
}

// ─── Backing store ────────────────────────────────────────────────────────────