Struct BufferState 

pub struct BufferState<T, Route> {
    pub capacity: usize,
    pub overflow: OverflowPolicy,
    /* private fields */
}

Complete valid state product of a Buffer.

Fields

capacity: usize

Positive maximum accepted queue length.

overflow: OverflowPolicy

Exhaustive policy used at capacity.

Implementations

impl<T, Route> BufferState<T, Route>

pub fn len(&self) -> usize

Number of accepted values currently owned.

pub fn is_empty(&self) -> bool

Whether no accepted value is currently owned.

pub fn queued(&self) -> impl ExactSizeIterator<Item = &Buffered<T, Route>>

Iterate accepted values in release order.