Method register

nodedb/src/control/array_sync/outbound/delivery.rs:60–67

Register a session and return the `Receiver` end of its delivery channel. The sync listener drains this in its send loop.

(&self, session_id: String)

    /// Register a session and return the `Receiver` end of its delivery
    /// channel.  The sync listener drains this in its send loop.
    pub fn register(&self, session_id: String) -> mpsc::Receiver<ArrayFrame> {
        let (tx, rx) = mpsc::channel(CHANNEL_CAPACITY);
        let mut sessions = self.sessions.write().unwrap_or_else(|p| p.into_inner());
        sessions.insert(session_id.clone(), tx);
        self.sessions_registered.fetch_add(1, Ordering::Relaxed);
        info!(session = %session_id, "array_delivery: session registered");
        rx
    }

    /// Unregister a disconnected session and drop its sender.
    pub fn unregister(&self, session_id: &str) {