Struct nolock::queues::spsc::unbounded::AsyncUnboundedReceiver [−][src]
pub struct AsyncUnboundedReceiver<T> { /* fields omitted */ }
Expand description
This is the async Variant of the UnboundedReceiver
.
Created using async_queue
Implementations
pub fn dequeue<'queue>(&'queue mut self) -> DequeueFuture<'queue, T>ⓘNotable traits for DequeueFuture<'queue, T>
impl<'queue, T> Future for DequeueFuture<'queue, T> type Output = Result<T, DequeueError>;
pub fn dequeue<'queue>(&'queue mut self) -> DequeueFuture<'queue, T>ⓘNotable traits for DequeueFuture<'queue, T>
impl<'queue, T> Future for DequeueFuture<'queue, T> type Output = Result<T, DequeueError>;
Dequeues the next Item from the Queue
This attempts to dequeue the next Item from the Queue.
This behaves just like the normal
try_dequeue
-Operation
Trait Implementations
Auto Trait Implementations
impl<T> !RefUnwindSafe for AsyncUnboundedReceiver<T>
impl<T> Send for AsyncUnboundedReceiver<T>
impl<T> Sync for AsyncUnboundedReceiver<T>
impl<T> Unpin for AsyncUnboundedReceiver<T>
impl<T> !UnwindSafe for AsyncUnboundedReceiver<T>