Struct rust_mqtt::network::NetworkConnection

pub struct NetworkConnection<T>where
    T: Read + Write,{ /* private fields */ }

Implementations

impl<T> NetworkConnection<T>where
    T: Read + Write,

Network connection represents an established TCP connection.

pub fn new(io: T) -> Self

Create a new network handle using the provided IO implementation.

pub async fn send(&mut self, buffer: &[u8]) -> Result<(), ReasonCode>

Send the data from buffer via TCP connection.

pub async fn receive(&mut self, buffer: &mut [u8]) -> Result<usize, ReasonCode>

Receive data to the buffer from TCP connection.