Struct BoundedSendQueue 

pub struct BoundedSendQueue<T> { /* private fields */ }

Bounded send queue for outbound endpoint envelopes (typed via T).

Implementations

impl<T> BoundedSendQueue<T>

pub fn new(capacity: usize, policy: SendQueueOverflow) -> Self

pub fn try_push(&mut self, item: T) -> Result<SendOutcome, RemoteError>

Try to enqueue item. Honours the configured overflow policy.

pub fn pop(&mut self) -> Option<T>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn capacity(&self) -> usize