pub struct MqttSink(_);
Implementations§
source§impl MqttSink
impl MqttSink
sourcepub fn ready(&self) -> impl Future<Output = bool>
pub fn ready(&self) -> impl Future<Output = bool>
Get notification when packet could be send to the peer.
Result indicates if connection is alive
sourcepub fn force_close(&self)
pub fn force_close(&self)
Force close MQTT connection. Dispatcher does not wait for uncompleted responses (ending them with error), but it flushes buffers.
sourcepub fn close_with_reason(&self, pkt: Disconnect)
pub fn close_with_reason(&self, pkt: Disconnect)
Close mqtt connection
sourcepub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilderwhere
ByteString: From<U>,
pub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilderwhere
ByteString: From<U>,
Create publish packet builder
sourcepub fn publish_packet(&self, packet: Publish) -> PublishBuilder
pub fn publish_packet(&self, packet: Publish) -> PublishBuilder
Create publish builder with publish packet
sourcepub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder
pub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder
Create subscribe packet builder
sourcepub fn unsubscribe(&self) -> UnsubscribeBuilder
pub fn unsubscribe(&self) -> UnsubscribeBuilder
Create unsubscribe packet builder