Struct MemoryRealtimeDelivery 

pub struct MemoryRealtimeDelivery<M> { /* private fields */ }

Runtime-independent bounded or unbounded outbound delivery recorder.

Bounded instances expose the contract semantics of wait, reject, and drop backpressure. Draining the queue wakes pending waiters.

Implementations

impl<M> MemoryRealtimeDelivery<M>

pub const fn new() -> Self

Creates an unbounded recorder that accepts every delivery.

pub const fn bounded(capacity: NonZeroUsize) -> Self

Creates a recorder with explicit non-zero queue capacity.

pub fn len(&self) -> SoapResult<usize>

Returns the current accepted queue length.

pub fn is_empty(&self) -> SoapResult<bool>

Reports whether no accepted deliveries are queued.

pub fn drain(&self) -> SoapResult<Vec<OutboundDelivery<M>>>

Removes every accepted delivery in enqueue order and wakes waiters.

Trait Implementations

impl<M> Default for MemoryRealtimeDelivery<M>

fn default() -> Self

Returns the “default value” for a type.

impl<M> RealtimeDelivery<M> for MemoryRealtimeDelivery<M>

where M: Send,

fn deliver( &self, delivery: OutboundDelivery<M>, ) -> BoxFuture<'_, SoapResult<DeliveryOutcome>>

Delivers one message or reports a safe failure.