pub fn async_req(
        &self,
        handle: &Handle,
        msg: &mut Msg,
    ) -> Result<AsyncReq, TibrvError> {
        let inbox = self.create_inbox()?;
        let sub = self.async_sub(handle, &inbox)?;

        msg.set_reply_subject(&inbox)?;
        self.send(msg)?;

        Ok(AsyncReq::new(sub))
    }
/// Asynchronously send a request on the given subject.
///
/// Returns an `AsyncReq` future representing the response.
Asynchronously send a request on the given subject.
Returns an `AsyncReq` future representing the response.
Asynchronously send a request on the given subject . Returns an ` AsyncReq ` future representing the response .
pub fn async_req(
        &self,
        handle: &Handle,
        msg: &mut Msg,
    ) -> Result<AsyncReq, TibrvError> {
        let inbox = self.create_inbox()?;
        let sub = self.async_sub(handle, &inbox)?;
        msg.set_reply_subject(&inbox)?;
        self.send(msg)?;
        Ok(AsyncReq::new(sub))
    }
pub fn async_req ( & self , handle : & Handle , msg : & mut Msg , ) -> Result < AsyncReq , TibrvError > { let inbox = self . create_inbox ( ) ? ; let sub = self . async_sub ( handle , & inbox ) ? ; msg . set_reply_subject ( & inbox ) ? ; self . send ( msg ) ? ; Ok ( AsyncReq :: new ( sub ) ) }
Asynchronously send a request on the given subject.
Asynchronously send a request on the given subject .
&self
handle
&Handle
msg
&mut Msg
&self
handle
&Handle
msg
&mut Msg