Trait Receiver

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

Required Methods§

Source

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

Implementors§

Source§

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