Trait concurrency_traits::TimeoutQueue[−][src]

pub trait TimeoutQueue: Queue {
    fn push_timeout(
        &self, 
        value: Self::Item, 
        timeout: Duration
    ) -> Result<(), Self::Item>;

    fn pop_timeout(&self, timeout: Duration) -> Option<Self::Item>;
}

A Queue that can timeout on push and pop operations

Required methods

fn push_timeout(
    &self,
    value: Self::Item,
    timeout: Duration
) -> Result<(), Self::Item>[src]

Appends an item to the end of the queue blocking until appended or timeout

fn pop_timeout(&self, timeout: Duration) -> Option<Self::Item>[src]

Blocks until an item is received from the queue or timeout

Loading content...

Implementors

impl<T: ?Sized> TimeoutQueue for T where
    T: Deref,
    T::Target: TimeoutQueue, [src]

Loading content...