Method load

nodedb/src/control/array_sync/outbound/subscriber_state.rs:236–242

Load a subscriber cursor, returning `None` if not found.

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

    /// Load a subscriber cursor, returning `None` if not found.
    fn load(&self, session_id: &str, array_name: &str) -> Option<ArraySubscriberState> {
        let key = Self::cursor_key(session_id, array_name);
        let txn = self.db.begin_read().ok()?;
        let table = txn.open_table(CURSOR_TABLE).ok()?;
        let entry = table.get(key.as_str()).ok()??;
        zerompk::from_msgpack(entry.value()).ok()
    }

    /// Delete all cursors for a given session (disconnect cleanup).
    fn delete_session(&self, session_id: &str) {