[][src]Trait rumq_client::MqttRead

pub trait MqttRead: ReadBytesExt {
    fn mqtt_read(&mut self) -> Result<Packet, Error> { ... }
fn read_packet_type_and_remaining_length(
        &mut self
    ) -> Result<(u8, usize), Error> { ... }
fn deserialize(
        &mut self,
        byte1: u8,
        remaining_len: usize
    ) -> Result<Packet, Error> { ... }
fn read_connect(&mut self) -> Result<Connect, Error> { ... }
fn read_connack(&mut self, remaining_len: usize) -> Result<Connack, Error> { ... }
fn read_publish(
        &mut self,
        byte1: u8,
        remaining_len: usize
    ) -> Result<Publish, Error> { ... }
fn read_subscribe(
        &mut self,
        remaining_len: usize
    ) -> Result<Subscribe, Error> { ... }
fn read_suback(&mut self, remaining_len: usize) -> Result<Suback, Error> { ... }
fn read_unsubscribe(
        &mut self,
        remaining_len: usize
    ) -> Result<Unsubscribe, Error> { ... }
fn read_mqtt_string(&mut self) -> Result<String, Error> { ... }
fn header_len(&self, remaining_len: usize) -> usize { ... }
fn read_remaining_length(&mut self) -> Result<usize, Error> { ... } }

Mqtt awareness on top of Read

Provided methods

fn mqtt_read(&mut self) -> Result<Packet, Error>

fn read_packet_type_and_remaining_length(
    &mut self
) -> Result<(u8, usize), Error>

fn deserialize(
    &mut self,
    byte1: u8,
    remaining_len: usize
) -> Result<Packet, Error>

fn read_connect(&mut self) -> Result<Connect, Error>

fn read_connack(&mut self, remaining_len: usize) -> Result<Connack, Error>

fn read_publish(
    &mut self,
    byte1: u8,
    remaining_len: usize
) -> Result<Publish, Error>

fn read_subscribe(&mut self, remaining_len: usize) -> Result<Subscribe, Error>

fn read_suback(&mut self, remaining_len: usize) -> Result<Suback, Error>

fn read_unsubscribe(
    &mut self,
    remaining_len: usize
) -> Result<Unsubscribe, Error>

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

fn header_len(&self, remaining_len: usize) -> usize

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

Loading content...

Implementors

impl<R> MqttRead for R where
    R: ReadBytesExt + ?Sized
[src]

Implement MattRead for every AsyncReadExt type (and hence AsyncRead type)

Loading content...