Struct Connect

pub struct Connect {
    pub protocol: Protocol,
    pub clean_start: bool,
    pub keep_alive: u16,
    pub properties: ConnectProperties,
    pub client_id: Arc<String>,
    pub last_will: Option<LastWill>,
    pub username: Option<Arc<String>>,
    pub password: Option<Bytes>,
}

Body type of CONNECT packet.

Fields

protocol: Protocol

The protocol version.

clean_start: bool

Clean start flag. This value specifies whether the Connection starts a new Session or is a continuation of an existing Session.

keep_alive: u16

The keep alive. A time interval measured in seconds. It is the maximum time interval that is permitted to elapse between the point at which the Client finishes transmitting one MQTT Control Packet and the point it starts sending the next.

properties: ConnectProperties

Properties

client_id: Arc<String>

The client identifier (ClientID).

last_will: Option<LastWill>

The will message.

username: Option<Arc<String>>

The user name.

password: Option<Bytes>

The password.

Implementations

impl Connect

pub fn new(client_id: Arc<String>, keep_alive: u16) -> Self

pub async fn decode_async<T: AsyncRead + Unpin>( reader: &mut T, header: Header, ) -> Result<Self, ErrorV5>

pub async fn decode_with_protocol<T: AsyncRead + Unpin>( reader: &mut T, header: Header, protocol: Protocol, ) -> Result<Self, ErrorV5>

Trait Implementations

impl Clone for Connect

fn clone(&self) -> Connect

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Connect

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

Formats the value using the given formatter.

impl Encodable for Connect

fn encode<W: SyncWrite>(&self, writer: &mut W) -> Result<(), Error>

Encode type into writer

fn encode_len(&self) -> usize

Calculate the encoded size.

impl From<Connect> for Packet

fn from(p: Connect) -> Self

Converts to this type from the input type.

impl PartialEq for Connect

fn eq(&self, other: &Connect) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Connect

impl StructuralPartialEq for Connect