Struct MqttClient

pub struct MqttClient<F> { /* private fields */ }

Type-safe MQTT client with automatic subscription management.

Provides typed publishers and subscribers with automatic serialization. Connection lifecycle is managed separately via MqttConnection.

Implementations

impl<F> MqttClient<F>

where F: Default + Clone + Send + Sync + 'static,

pub async fn connect( url: &str, ) -> Result<(MqttClient<F>, MqttConnection), MqttClientError>

Create MQTT client with default configuration.

Returns both client and connection handle. Keep connection alive for the session duration, call connection.shutdown() when done.

pub async fn connect_with_config( config: MqttClientConfig<F>, ) -> Result<(MqttClient<F>, MqttConnection), MqttClientError>

Create a new MQTT client with custom configuration

pub fn get_publisher<T>( &self, topic: impl Into<ArcStr>, ) -> Result<MqttPublisher<T, F>, TopicError>

where F: MessageSerializer<T>,

Create typed publisher for specific topic.

Topic must not contain wildcard characters (+, #).

pub async fn subscribe<T>( &self, topic: impl TryInto>, ) -> Result<MqttSubscriber<T, F>, MqttClientError>

where T: 'static + Send + Sync, F: MessageSerializer<T>, <impl TryInto<TopicPatternPath> as TryInto<TopicPatternPath>>::Error: Into<MqttClientError>,

Subscribe to topic pattern with default configuration.

Supports MQTT wildcards: + (single level), # (multi-level).

pub async fn subscribe_with_config<T>( &self, topic: impl TryInto>, config: SubscriptionConfig, ) -> Result<MqttSubscriber<T, F>, MqttClientError>

where T: 'static + Send + Sync, F: MessageSerializer<T>, <impl TryInto<TopicPatternPath> as TryInto<TopicPatternPath>>::Error: Into<MqttClientError>,

Subscribe with custom configuration (QoS, caching strategy)

Trait Implementations

impl<F> Clone for MqttClient<F>

where F: Clone,

fn clone(&self) -> MqttClient<F>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<F> Debug for MqttClient<F>

where F: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.