Struct BoundedEventSender 

pub struct BoundedEventSender { /* private fields */ }

Bounded event sender: item capacity + byte budget (D-015).

Implementations

impl BoundedEventSender

pub fn new(tx: Sender<QueuedEvent>, max_bytes: usize) -> Self

Wrap an mpsc sender with a shared byte counter.

pub async fn send(&self, item: QueuedEvent) -> Result<(), EventQueueFull>

Try to enqueue; fails closed when item or byte budget is exceeded.

Byte reservation is cancellation-safe (D-027): if the caller cancels while awaiting item capacity, the Drop guard restores the reserved bytes so a later terminal event can still be queued.

pub fn byte_counter(&self) -> Arc<AtomicUsize>

Shared counter for the delivery task.

Trait Implementations

impl Clone for BoundedEventSender

fn clone(&self) -> BoundedEventSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.