Trait Consumer 

pub trait Consumer<T: Send>: Debug + Send {
    // Required method
    fn recv<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Delivery<T>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Pulls work items from a queue for processing.

Required Methods

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<Delivery<T>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The next delivery, or None once the queue is closed and drained.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors