pub async fn pull(&self) -> Result<Option<Box<dyn Message<T> + Send>>> {
        let mut subscription_guard = self.subscription.lock().await;
        match subscription_guard
            .receive_timeout(time::Duration::from_secs(5))
            .await
        {
            Some(m) => Ok(Some(Box::from(Format::from(m)))),
            None => Ok(None),
        }
    }
/// Pull a message from the subscription.
Pull a message from the subscription.
Pull a message from the subscription .
pub async fn pull(&self) -> Result<Option<Box<dyn Message<T> + Send>>> {
        let mut subscription_guard = self.subscription.lock().await;
        match subscription_guard
            .receive_timeout(time::Duration::from_secs(5))
            .await
        {
            Some(m) => Ok(Some(Box::from(Format::from(m)))),
            None => Ok(None),
        }
    }
pub async fn pull ( & self ) -> Result < Option < Box < dyn Message < T > + Send > > > { let mut subscription_guard = self . subscription . lock ( ) . await ; match subscription_guard . receive_timeout ( time :: Duration :: from_secs ( 5 ) ) . await { Some ( m ) => Ok ( Some ( Box :: from ( Format :: from ( m ) ) ) ) , None => Ok ( None ) , } }
Pull a message from the subscription.
Pull a message from the subscription .
&self