Struct rust_mqtt::utils::buffer_reader::BuffReader

pub struct BuffReader<'a> {
    pub position: usize,
    /* private fields */
}

Buff reader is reading corresponding types from buffer (Byte array) and stores current position (later as cursor)

Fields

position: usize

Implementations

impl<'a> BuffReader<'a>

pub fn increment_position(&mut self, increment: usize)

pub fn new(buffer: &'a [u8], buff_len: usize) -> Self

pub fn read_variable_byte_int(&mut self) -> Result<u32, BufferError>

Variable byte integer can be 1-4 Bytes long. Buffer reader takes all 4 Bytes at first and than check what is true length of varbyteint and increment cursor by that

pub fn read_u32(&mut self) -> Result<u32, BufferError>

Reading u32 from buffer as Big endian

pub fn read_u16(&mut self) -> Result<u16, BufferError>

Reading u16 from buffer as Big endinan

pub fn read_u8(&mut self) -> Result<u8, BufferError>

Reading one byte from buffer as Big endian

pub fn read_string(&mut self) -> Result<EncodedString<'a>, BufferError>

Reading UTF-8 encoded string from buffer

pub fn read_binary(&mut self) -> Result<BinaryData<'a>, BufferError>

Read Binary data from buffer

pub fn read_string_pair(&mut self) -> Result<StringPair<'a>, BufferError>

Read string pair from buffer

pub fn read_message(&mut self, total_len: usize) -> &'a [u8]

Read payload message from buffer

pub fn peek_u8(&self) -> Result<u8, BufferError>

Peeking (without incremental internal pointer) one byte from buffer as Big endian