Struct mu_rust_message_client::MessageClient
source · pub struct MessageClient { /* private fields */ }
Implementations§
source§impl MessageClient
impl MessageClient
pub async fn new(agent: &str) -> Result<MessageClient, MessageClientError>
pub async fn subscribe(&mut self, topic: &str) -> Result<(), MessageClientError>
pub async fn recv(&mut self) -> Option<Result<Exchange, MessageClientError>>
pub async fn send( &mut self, message: Exchange ) -> Result<(), MessageClientError>
pub fn spawn_send(self) -> (Sender<Exchange>, JoinHandle<()>)
Trait Implementations§
source§impl Debug for MessageClient
impl Debug for MessageClient
Auto Trait Implementations§
impl !RefUnwindSafe for MessageClient
impl Send for MessageClient
impl Sync for MessageClient
impl Unpin for MessageClient
impl !UnwindSafe for MessageClient
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