Method has_subscribers

nodedb/src/event/crdt_sync/delivery.rs:163–170

Check if any connected Lite session subscribes to this collection.

(&self, tenant_id: u64, collection: &str)

    /// Check if any connected Lite session subscribes to this collection.
    pub fn has_subscribers(&self, tenant_id: u64, collection: &str) -> bool {
        let sessions = self.sessions.read().unwrap_or_else(|p| p.into_inner());
        sessions.values().any(|s| {
            s.tenant_id == tenant_id
                && (s.subscribed_collections.is_empty()
                    || s.subscribed_collections.iter().any(|c| c == collection))
        })
    }

    /// Enqueue an outbound delta for delivery to all matching sessions.
    ///