Trait app_frame::queue_consumer::Receiver

pub trait Receiver<T: Hash + Eq> {
    // Required method
    fn receiver(
        &self,
        config: QueueReceiveConfig,
        sleeper: Arc<dyn Sleeper>
    ) -> QueueReceiver<T>;
}

Required Methods

fn receiver( &self, config: QueueReceiveConfig, sleeper: Arc<dyn Sleeper> ) -> QueueReceiver<T>

Implementors

impl<T: Hash + Eq + Clone> Receiver<T> for Queue<T>