Struct mpmcpq::ReceiveGuard

pub struct ReceiveGuard<'a, M, P>where
    M: Send,
    P: PartialOrd + Ord,{ /* private fields */ }

Wraps a Message, when dropped and the queue is empty it sends a final ‘Drained’ message to notify that there is no further work in progress.

Implementations

impl<'a, M, P> ReceiveGuard<'a, M, P>where
    M: Send,
    P: PartialOrd + Ord,

pub fn message(&self) -> &Message<M, P>

Returns a reference to the contained message.

pub fn into_message(self) -> Message<M, P>

Takes the Message out of a ReceiveGuard, drop the guard (and by that, may send the ‘Drained’ message).

Trait Implementations

impl<'a, M, P> Debug for ReceiveGuard<'a, M, P>where
    M: Send + Debug,
    P: PartialOrd + Ord + Debug,

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

Formats the value using the given formatter.

impl<M, P> Drop for ReceiveGuard<'_, M, P>where
    M: Send,
    P: PartialOrd + Ord,

fn drop(&mut self)

Executes the destructor for this type.