Struct SeamQueue 

pub struct SeamQueue { /* private fields */ }

One seam’s bounded queue. Clones share the queue.

Implementations

impl SeamQueue

pub fn new(in_flight: u32, capacity: u32) -> Result<Self, String>

Both limits must lie in 1 to MAX_SEAM_LIMIT.

pub fn try_enter(&self) -> Result<Slot, QueueFull>

Admit a call, or refuse it at once when the queue is full.

pub fn count_late(&self)

Count a response discarded because its caller stopped waiting.

pub fn counters(&self) -> SeamCounters

Trait Implementations

impl Clone for SeamQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SeamQueue

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

Formats the value using the given formatter.