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]
&self,
value: Self::Item,
timeout: Duration
) -> Result<(), Self::Item>
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
Implementors
impl<T: ?Sized> TimeoutQueue for T where
T: Deref,
T::Target: TimeoutQueue,
[src]
impl<T: ?Sized> TimeoutQueue for T where
T: Deref,
T::Target: TimeoutQueue,
[src]