Trait mqtt311::MqttRead

pub trait MqttRead: ReadBytesExt {
    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

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>

Loading content...

Implementations on Foreign Types

impl MqttRead for TcpStream

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>

impl MqttRead for Cursor<Vec<u8>>

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>

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

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>

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

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>

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

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>

Loading content...

Implementors

Loading content...