Struct ntex_mqtt::v5::client::Client

pub struct Client<Io> { /* fields omitted */ }

Mqtt client

Implementations

impl<Io> Client<Io> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static, 

pub fn sink(&self) -> MqttSink

Get client sink

pub fn session_present(&self) -> bool

Indicates whether there is already stored Session state

pub fn packet(&self) -> &ConnectAck

Get reference to ConnectAck packet

pub fn packet_mut(&mut self) -> &mut ConnectAck

Get mutable reference to ConnectAck packet

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

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> + 'static,
    S: Service<Request = ControlMessage<E>, Response = ControlResult, Error = E> + 'static, 

Run client with provided control messages handler