/// Get the next message available on this subscription.
///
/// Blocks until a message is available in the queue.
Get the next message available on this subscription.
Blocks until a message is available in the queue.
Get the next message available on this subscription . Blocks until a message is available in the queue .
pub fn next(&self) -> Result<Msg, TibrvError> {
        if let Ok(m) = self.channel.try_recv() {
            return Ok(m);
        }
        self.dispatch()?;
        self.channel
            .recv()
            .context(ErrorKind::QueueError)
            .map_err(TibrvError::from)
    }
pub fn next ( & self ) -> Result < Msg , TibrvError > { if let Ok ( m ) = self . channel . try_recv ( ) { return Ok ( m ) ; } self . dispatch ( ) ? ; self . channel . recv ( ) . context ( ErrorKind :: QueueError ) . map_err ( TibrvError :: from ) }
Get the next message available on this subscription.
Get the next message available on this subscription .
&self