Struct ntex_mqtt::v5::MqttSink

pub struct MqttSink(_, _);

Implementations

impl MqttSink

pub fn is_opened(&self) -> bool

Check connection status

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 with default Disconnect message

pub fn close_with_reason(&self, pkt: Disconnect)

Close mqtt connection

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

Create publish packet builder

pub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder

Create subscribe packet builder

pub fn unsubscribe(&self) -> UnsubscribeBuilder

Create unsubscribe packet builder

Trait Implementations

impl Clone for MqttSink

pub 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

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

Formats the value using the given formatter.