Struct MIPClient 

pub struct MIPClient { /* private fields */ }

Async MIP protocol client with auto-reconnection support

Implementations

impl MIPClient

pub fn new(options: MIPClientOptions) -> Self

pub fn is_connected(&self) -> bool

Check if the client is connected

pub fn on_connect<F>(&mut self, callback: F) -> &mut Self

where F: Fn() + Send + Sync + 'static,

Register connect event callback

pub fn on_disconnect<F>(&mut self, callback: F) -> &mut Self

where F: Fn() + Send + Sync + 'static,

Register disconnect event callback

pub fn on_reconnecting<F>(&mut self, callback: F) -> &mut Self

where F: Fn(u32) + Send + Sync + 'static,

Register reconnecting event callback

pub fn on_message<F>(&mut self, callback: F) -> &mut Self

where F: Fn(MIPMessage) + Send + Sync + 'static,

Register message event callback

pub fn on_event<F>(&mut self, callback: F) -> &mut Self

where F: Fn(MIPMessage) + Send + Sync + 'static,

Register event callback

pub fn on_ack<F>(&mut self, callback: F) -> &mut Self

where F: Fn(u64) + Send + Sync + 'static,

Register ACK event callback

pub fn on_pong<F>(&mut self, callback: F) -> &mut Self

where F: Fn() + Send + Sync + 'static,

Register pong event callback

pub fn on_error<F>(&mut self, callback: F) -> &mut Self

where F: Fn(MIPError) + Send + Sync + 'static,

Register error event callback

pub fn on_frame<F>(&mut self, callback: F) -> &mut Self

where F: Fn(Header, Vec<u8>) + Send + Sync + 'static,

Register raw frame event callback

pub async fn connect(&mut self) -> MIPResult<()>

Connect to the MIP server

pub async fn disconnect(&mut self) -> MIPResult<()>

Disconnect from the server

pub fn subscribe(&self, topic: &str, require_ack: bool) -> MIPResult<u64>

Subscribe to a topic

pub fn unsubscribe(&self, topic: &str, require_ack: bool) -> MIPResult<u64>

Unsubscribe from a topic

pub fn publish( &self, topic: &str, message: &str, flags: FrameFlags, ) -> MIPResult<u64>

Publish a message to a topic

pub fn ping(&self) -> MIPResult<u64>

Send a ping to the server

pub fn send_raw_frame( &self, frame_type: FrameType, payload: &[u8], flags: FrameFlags, ) -> MIPResult<u64>

Send raw frame (advanced usage)

Trait Implementations

impl Drop for MIPClient

fn drop(&mut self)

Executes the destructor for this type.