/// Asynchronously subscribe to a message subject.
///
/// Sets up the queue and channels as in a synchronous subscription, and
/// returns an `AsyncSub` stream.
Asynchronously subscribe to a message subject.
Sets up the queue and channels as in a synchronous subscription, and
returns an `AsyncSub` stream.
Asynchronously subscribe to a message subject . Sets up the queue and channels as in a synchronous subscription and returns an ` AsyncSub ` stream .
pub fn async_sub(
        &self,
        handle: &Handle,
        subject: &str,
    ) -> Result<AsyncSub, TibrvError> {
        AsyncQueue::new(self.context.clone())?.subscribe(handle, &self, subject)
    }
pub fn async_sub ( & self , handle : & Handle , subject : & str , ) -> Result < AsyncSub , TibrvError > { AsyncQueue :: new ( self . context . clone ( ) ) ? . subscribe ( handle , & self , subject ) }
Asynchronously subscribe to a message subject.
Asynchronously subscribe to a message subject .
&self
handle
&Handle
subject
&str