Struct TransactionEventSender 

pub struct TransactionEventSender { /* private fields */ }

Runtime-held half of the event mailbox.

Implementations

impl TransactionEventSender

pub fn max_event_items(&self) -> usize

Maximum queued event items installed at construction.

pub fn max_event_bytes(&self) -> usize

Maximum event payload bytes accepted by this mailbox.

pub fn queued_bytes(&self) -> u64

Best-effort queued byte count.

pub fn try_send(&self, event: TransactionEvent) -> Result<(), EventEnqueueError>

Try to enqueue without waiting.

pub async fn send( &self, event: TransactionEvent, ) -> Result<(), EventEnqueueError>

Enqueue, waiting until byte and item capacity are available or the receiver is dropped (D-047 lossless wait-for-capacity).

Callers that need a bounded wait MUST wrap this future in tokio::select! with a deadline / cancel.

Trait Implementations

impl Clone for TransactionEventSender

fn clone(&self) -> TransactionEventSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionEventSender

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

Formats the value using the given formatter.