Struct SubjectSubscribers 

pub struct SubjectSubscribers {
    pub fanout: Sender<Arc<EventEnvelope>>,
    pub groups: HashMap<String, Vec<QueueGroupMember>>,
}

Pre-partitioned subscribers for a single subject.

Fanout uses a broadcast channel: one send() delivers to all receivers without per-subscriber cloning — the Arc is cloned internally.

Queue groups keep per-member mpsc channels for round-robin selection.

Fields

fanout: Sender<Arc<EventEnvelope>>

Broadcast channel for fanout delivery.

groups: HashMap<String, Vec<QueueGroupMember>>

Queue groups: one member per group receives each message.

Implementations

impl SubjectSubscribers

pub fn new(capacity: usize) -> Self

pub fn subscribe_fanout(&self) -> Receiver<Arc<EventEnvelope>>

Create a new fanout receiver from the broadcast channel.

pub fn add_to_groups( &mut self, member: QueueGroupMember, queue_groups: &[String], )

Add a member to one or more queue groups.

pub fn remove_from_groups(&mut self, id: SubscriptionId)

Remove a member by id from all queue groups.

pub fn is_empty(&self) -> bool

true if no fanout receivers and no group members remain.