Struct BroadcastSlotHandle 

pub struct BroadcastSlotHandle<M, K>
where
    M: Send + Sync + Clone + 'static,
    K: Send + Sync + Clone + 'static,
{ /* private fields */ }

Available on crate features extractors and reassembler and session only.

Per-subscriber broadcast handle. Each Clone yields a new subscriber with its own private queue; every push to the owning slot fans out to every live subscriber.

Comparison with super::SlotHandle

Aspect	SlotHandle	BroadcastSlotHandle
Clone semantics	Competitive consumer (MPMC)	Broadcast (every clone sees every message)
Per-push cost	O(1) atomic	O(subscribers) clones + pushes
M bound	Send	Send + Clone
Memory per subscriber	Shares one queue	One private queue each

Drop semantics

Dropping a subscriber removes its queue from the broadcast set on the next push (best-effort prune via Weak::upgrade). Slow subscribers’ queues grow until they’re drained or dropped — bound externally via Self::drain_n from plan 149.

Implementations

impl<M, K> BroadcastSlotHandle<M, K>

where M: Send + Sync + Clone + 'static, K: Send + Sync + Clone + 'static,

pub fn drain(&mut self, out: &mut Vec<SlotMessage<M, K>>) -> usize

Drain every message this subscriber has received since the last call, into out. Returns the count.

pub fn drain_n(&mut self, out: &mut Vec<SlotMessage<M, K>>, max: usize) -> usize

Bounded variant — drain at most max messages.

pub fn pending(&self) -> usize

Pending message count for this subscriber.

pub fn subscribers(&self) -> usize

Active subscriber count across the broadcast set (best-effort; read under a lock).

pub fn parser_kind(&self) -> ParserKind

Parser-kind identity from registration.

Trait Implementations

impl<M, K> Clone for BroadcastSlotHandle<M, K>

where M: Send + Sync + Clone + 'static, K: Send + Sync + Clone + 'static,

fn clone(&self) -> Self

New subscriber: gets its own queue inside the broadcast set. Subsequent pushes go to every live queue. The new subscriber sees only messages pushed AFTER this clone call (no replay of earlier pushes).

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M, K> Debug for BroadcastSlotHandle<M, K>

where M: Send + Sync + Clone + 'static, K: Send + Sync + Clone + 'static,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M, K> SlotDrain<M, K> for BroadcastSlotHandle<M, K>

where M: Send + Sync + Clone + 'static, K: Send + Sync + Clone + 'static,

fn drain(&mut self, out: &mut Vec<SlotMessage<M, K>>) -> usize

Drain all currently-queued messages into out. Returns the count drained.

fn drain_n(&mut self, out: &mut Vec<SlotMessage<M, K>>, max: usize) -> usize

Drain at most max messages into out. Returns the count drained (<= max).

fn pending(&self) -> usize

Number of messages currently queued for this handle.

fn parser_kind(&self) -> ParserKind

Typed parser-kind identity for the registered parser.