pub fn pull<T: DeserializeOwned + Send + 'static>(
        &self,
    ) -> Result<Option<Box<dyn Message<T> + Send>>> {
        let mut queue_guard = self.lock()?;
        let queue = &mut queue_guard;

        match queue.pop_front() {
            Some(m) => Ok(Some(Box::from(m))),
            None => Ok(None),
        }
    }
/// Pulls a single message from the queue.
Pulls a single message from the queue.
Pulls a single message from the queue .
pub fn pull<T: DeserializeOwned + Send + 'static>(
        &self,
    ) -> Result<Option<Box<dyn Message<T> + Send>>> {
        let mut queue_guard = self.lock()?;
        let queue = &mut queue_guard;
        match queue.pop_front() {
            Some(m) => Ok(Some(Box::from(m))),
            None => Ok(None),
        }
    }
pub fn pull < T : DeserializeOwned + Send + ' static > ( & self , ) -> Result < Option < Box < dyn Message < T > + Send > > > { let mut queue_guard = self . lock ( ) ? ; let queue = & mut queue_guard ; match queue . pop_front ( ) { Some ( m ) => Ok ( Some ( Box :: from ( m ) ) ) , None => Ok ( None ) , } }
Pulls a single message from the queue.
Pulls a single message from the queue .
&self