pub struct Host { /* private fields */ }Implementations§
Source§impl Host
impl Host
Sourcepub fn publish(
&self,
subject: String,
reply_to: String,
body: Vec<u8>,
) -> HandlerResult<PublishResponse>
pub fn publish( &self, subject: String, reply_to: String, body: Vec<u8>, ) -> HandlerResult<PublishResponse>
Publish a message on a given subject. If a reply is not expected, the value can be left as an empty string.
Sourcepub fn request(
&self,
subject: String,
body: Vec<u8>,
timeout: i64,
) -> HandlerResult<BrokerMessage>
pub fn request( &self, subject: String, body: Vec<u8>, timeout: i64, ) -> HandlerResult<BrokerMessage>
Request a response on a given subject in a given timeout
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Host
impl RefUnwindSafe for Host
impl Send for Host
impl Sync for Host
impl Unpin for Host
impl UnwindSafe for Host
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more