Struct Client

pub struct Client<Io, St> { /* private fields */ }

Mqtt client

Implementations

impl<Io, St> Client<Io, St>

where St: 'static,

pub fn new(client_id: ByteString) -> Self

Create new client and provide client id

pub fn protocol(self, val: Protocol) -> Self

Mqtt protocol version

pub fn clean_session(self, val: bool) -> Self

The handling of the Session state.

pub fn keep_alive(self, val: u16) -> Self

A time interval measured in seconds.

keep-alive is set to 30 seconds by default.

pub fn last_will(self, val: LastWill) -> Self

Will Message be stored on the Server and associated with the Network Connection.

by default last will value is not set

pub fn username(self, val: ByteString) -> Self

Username can be used by the Server for authentication and authorization.

pub fn password(self, val: Bytes) -> Self

Password can be used by the Server for authentication and authorization.

pub fn inflight(self, val: usize) -> Self

Number of in-flight concurrent messages.

in-flight is set to 15 messages

pub fn state<C, F>(self, state: F) -> ServiceBuilder<Io, St, C>

where F: IntoService<C>, Io: AsyncRead + AsyncWrite, C: Service<Request = ConnectAck<Io>, Response = ConnectAckResult<Io, St>>, C::Error: 'static,

Set state service

State service verifies connect ack packet and construct connection state.

Trait Implementations

impl<Io: Clone, St: Clone> Clone for Client<Io, St>

fn clone(&self) -> Client<Io, St>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.