Trait MqttRead

Source
pub trait MqttRead: ReadBytesExt {
    // Provided methods
    fn deserialize(
        &mut self,
        remaining_len: usize,
        header: Header,
    ) -> Result<Packet> { ... }
    fn read_packet(&mut self) -> Result<Packet> { ... }
    fn read_packet_with_len(&mut self) -> Result<(Packet, usize)> { ... }
    fn read_connect(&mut self, _: Header) -> Result<Connect> { ... }
    fn read_connack(&mut self, header: Header) -> Result<Connack> { ... }
    fn read_publish(&mut self, header: Header) -> Result<Publish> { ... }
    fn read_subscribe(&mut self, header: Header) -> Result<Subscribe> { ... }
    fn read_suback(&mut self, header: Header) -> Result<Suback> { ... }
    fn read_unsubscribe(&mut self, header: Header) -> Result<Unsubscribe> { ... }
    fn read_payload(&mut self, len: usize) -> Result<Box<Vec<u8>>> { ... }
    fn read_mqtt_string(&mut self) -> Result<String> { ... }
    fn read_remaining_length(&mut self) -> Result<usize> { ... }
}

Provided Methods§

Source

fn deserialize( &mut self, remaining_len: usize, header: Header, ) -> Result<Packet>

Source

fn read_packet(&mut self) -> Result<Packet>

Source

fn read_packet_with_len(&mut self) -> Result<(Packet, usize)>

Source

fn read_connect(&mut self, _: Header) -> Result<Connect>

Source

fn read_connack(&mut self, header: Header) -> Result<Connack>

Source

fn read_publish(&mut self, header: Header) -> Result<Publish>

Source

fn read_subscribe(&mut self, header: Header) -> Result<Subscribe>

Source

fn read_suback(&mut self, header: Header) -> Result<Suback>

Source

fn read_unsubscribe(&mut self, header: Header) -> Result<Unsubscribe>

Source

fn read_payload(&mut self, len: usize) -> Result<Box<Vec<u8>>>

Source

fn read_mqtt_string(&mut self) -> Result<String>

Source

fn read_remaining_length(&mut self) -> Result<usize>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl MqttRead for Cursor<Vec<u8>>

Source§

impl MqttRead for TcpStream

Source§

impl<'a> MqttRead for &'a [u8]

Source§

impl<T> MqttRead for Take<T>
where T: Read,

Source§

impl<T: Read> MqttRead for BufReader<T>

Implementors§