Method register

nodedb/src/control/array_sync/outbound/subscriber_state.rs:94–112

Register a new subscriber (or restore an existing one from the store). Returns the current `ArraySubscriberState` (may have a non-ZERO `last_pushed_hlc` if the subscriber previously connected).

(
        &self,
        session_id: &str,
        array_name: &str,
        coord_range: Option<ArrayCoordRange>,
    )

    /// Returns the current `ArraySubscriberState` (may have a non-ZERO
    /// `last_pushed_hlc` if the subscriber previously connected).
    pub fn register(
        &self,
        session_id: &str,
        array_name: &str,
        coord_range: Option<ArrayCoordRange>,
    ) -> ArraySubscriberState {
        let key = (session_id.to_string(), array_name.to_string());

        // Check persistent store for an existing cursor.
        let persisted = self.store.load(session_id, array_name);

        let state = persisted.unwrap_or_else(|| {
            ArraySubscriberState::new(session_id.to_string(), array_name.to_string(), coord_range)
        });

        let mut map = self.inner.write().unwrap_or_else(|p| p.into_inner());
        map.insert(key, state.clone());
        state
    }

    /// Update the cursor for `(session_id, array_name)` to `new_hlc`.
    ///