Struct ntex_mqtt::v3::MqttSink

pub struct MqttSink(_);

Implementations

impl MqttSink

pub fn credit(&self) -> usize

Get client receive credit

pub fn ready(&self) -> impl Future<Output = bool>

Get notification when packet could be send to the peer.

Result indicates if connection is alive

pub fn close(&self)

Close mqtt connection

pub fn force_close(&self)

Force close mqtt connection. mqtt dispatcher does not wait for uncompleted responses, but it flushes buffers.

pub fn publish(&self, topic: ByteString, payload: Bytes) -> PublishBuilder

Create publish message builder

pub fn subscribe(&self) -> SubscribeBuilder

Create subscribe packet builder

panics if id is 0

pub fn unsubscribe(&self) -> UnsubscribeBuilder

Create unsubscribe packet builder

Trait Implementations

impl Clone for MqttSink

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MqttSink

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

Formats the value using the given formatter.