Struct 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 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<E, U::Error>

where T: IntoPattern, F: IntoService<U, Publish>, U: Service<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, Control<E>> + 'static, S: Service<Control<E>, Response = ControlAck, 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.