Struct ntex_mqtt::v5::MqttSink

pub struct MqttSink(/* private fields */);

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’s 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 force_close(&self)

Force close MQTT connection. Dispatcher does not wait for uncompleted responses (ending them with error), but it flushes buffers.

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 publish_pkt(&self, packet: Publish) -> PublishBuilder

Create publish builder with publish packet

pub fn publish_ack_cb<F>(&self, f: F)

where F: Fn(PublishAck, bool) + 'static,

Set publish ack callback

Use non-blocking send, PublishBuilder::send_at_least_once_no_block() First argument is packet id, second argument is “disconnected” state

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

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.