Struct ntex_mqtt::v3::MqttSink

pub struct MqttSink(_);

Implementations

impl MqttSink

pub fn is_open(&self) -> bool

Check if io stream is open

pub fn is_ready(&self) -> bool

Check if sink is ready

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<U>(&self, topic: U, payload: Bytes) -> PublishBuilderwhere
    ByteString: From<U>,

Create publish message builder

pub fn publish_pkt(&self, packet: Publish) -> PublishBuilder

Create publish builder with publish packet

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.

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.