Struct ntex_mqtt::v3::Client

pub struct Client { /* private fields */ }

Mqtt client

Implementations

impl Client

pub fn sink(&self) -> MqttSink

Get client sink

pub fn session_present(&self) -> bool

Indicates whether there is already stored Session state

pub fn resource<T, F, U>(
    self,
    address: T,
    service: F
) -> ClientRouter<U::Error, U::Error>where
    T: IntoPattern,
    F: IntoService<U, Publish>,
    U: Service<Publish, Response = ()> + 'static,

Configure mqtt resource for a specific topic

pub async fn start_default(self)

Run client with default control messages handler.

Default handler closes connection on any control message.

pub async fn start<F, S, E>(self, service: F) -> Result<(), MqttError<E>>where
    E: 'static,
    F: IntoService<S, ControlMessage<E>> + 'static,
    S: Service<ControlMessage<E>, Response = ControlResult, Error = E> + 'static,

Run client with provided control messages handler

pub fn into_inner(self) -> (IoBoxed, Codec)

Get negotiated io stream and codec

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.