Struct actix_mqtt::client::Client

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

Mqtt client

Methods

impl<Io, St> Client<Io, St> where
    St: 'static, 

pub fn new(client_id: String<Bytes>) -> 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: String<Bytes>) -> 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.