Struct TcpConnectionState 

pub struct TcpConnectionState<'a, 'l, M: RawMutex, NETWORK, DNS, const BUFFER_SIZE: usize>
where
    NETWORK: TcpConnect,
    DNS: Dns,
{ /* private fields */ }

Implementations

impl<'a, 'l, M: RawMutex, NETWORK, DNS, const BUFFER_SIZE: usize> TcpConnectionState<'a, 'l, M, NETWORK, DNS, BUFFER_SIZE>

where NETWORK: TcpConnect, DNS: Dns,

pub fn new( network: &'a NETWORK, dns: DNS, last_will: Option<LastWill<'l>>, config: ClientConfig<'l>, ) -> Self

Trait Implementations

impl<'a, 'l, M: RawMutex, NETWORK, DNS, const BUFFER_SIZE: usize> ConnectionState for TcpConnectionState<'a, 'l, M, NETWORK, DNS, BUFFER_SIZE>

where NETWORK: TcpConnect, DNS: Dns,

fn get_state(&self) -> Option<ConnectionStateValue>

async fn on_state_change(&self) -> ConnectionStateValue

async fn disconnect(&self) -> Result<(), MqttError>

async fn connect(&self) -> Result<(), MqttError>

Establishes the connection to the broker

async fn await_connected(&self)

fn set_error(&self)

fn try_write_packet(&self, packet: &Packet<'_>) -> Result<bool, MqttError>

Send a mqtt packet to the broker This method may return without sending the packet returning Ok(false). This indicates that the send sould be tried later.

async fn write_packet(&self, packet: &Packet<'_>) -> Result<(), MqttError>

Writes a packet to the send buffer and sends data until teh packet fits

async fn run_io(&self) -> Result<impl Deref<Target = Packet<'_>>, MqttError>

Run pending io tasks until there is a new packet

async fn run_io_nonblocking( &self, ) -> Result<Option<impl Deref<Target = Packet<'_>>>, MqttError>

Run until there is a new packet or something has been sent