[−][src]Trait secc::SeccCoreOps

pub trait SeccCoreOps<T: Sync + Send + Clone> {
    fn core(&self) -> &SeccCore<T>;

    fn capacity(&self) -> usize { ... }

    fn awaited_messages(&self) -> usize { ... }

    fn awaited_capacity(&self) -> usize { ... }

    fn pending(&self) -> usize { ... }

    fn receivable(&self) -> usize { ... }

    fn sent(&self) -> usize { ... }

    fn received(&self) -> usize { ... }
}

Required methods

fn core(&self) -> &SeccCore<T>

Fetch the core of the channel.

Loading content...

Provided methods

fn capacity(&self) -> usize

Returns the capacity of the channel.

fn awaited_messages(&self) -> usize

Count of the number of times receivers of this channel waited for messages.

fn awaited_capacity(&self) -> usize

Count of the number of times senders to the channel waited for capacity.

fn pending(&self) -> usize

Returns the number of items are in the channel currently without regard to cursors.

fn receivable(&self) -> usize

Number of messages in the channel that are available to be received. This will normally be the same as pending unless there is a skip cursor active; in which case it may be smaller than pending or even 0.

fn sent(&self) -> usize

Returns the total number of messages that have been sent to the channel.

fn received(&self) -> usize

Returns the total number of messages that have been received from the channel.

Loading content...

Implementors

impl<T: Sync + Send + Clone> SeccCoreOps<T> for SeccReceiver<T>[src]

impl<T: Sync + Send + Clone> SeccCoreOps<T> for SeccSender<T>[src]

Loading content...