Struct MqttPublisher

pub struct MqttPublisher<T, F> { /* private fields */ }

Typed MQTT publisher for a specific topic.

Created via MqttClient::get_publisher(). Supports QoS and retain configuration.

Implementations

impl<T, F> MqttPublisher<T, F>

where F: MessageSerializer<T>,

pub fn new( client: AsyncClient, serializer: F, topic: impl Into<ArcStr>, ) -> MqttPublisher<T, F>

Internal constructor. Use MqttClient::get_publisher() instead.

pub fn with_qos(self, qos: QoS) -> MqttPublisher<T, F>

Sets Quality of Service level for published messages.

pub fn with_retain(self, retain: bool) -> MqttPublisher<T, F>

Sets retain flag for published messages.

pub fn topic(&self) -> &ArcStr

Get the topic this publisher is configured for.

pub fn qos(&self) -> QoS

Get qos level for this publisher.

pub fn retain(&self) -> bool

Get retain flag for this publisher.

pub async fn publish(&self, data: &T) -> Result<(), MqttClientError>

Publishes data to the configured topic.

pub async fn publish_retain(&self, data: &T) -> Result<(), MqttClientError>

Publishes data with retain flag explicitly set to true.

pub async fn publish_normal(&self, data: &T) -> Result<(), MqttClientError>

Publishes data with retain flag explicitly set to false.

pub async fn clear_retained(&self) -> Result<(), MqttClientError>

Clear retained message for this topic

Sends an empty payload with retain=true to remove any retained message. Uses the same QoS level as configured for this publisher.