[−][src]Trait rumq_client::MqttRead
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>
&mut self
) -> Result<(u8, usize), Error>
fn deserialize(
&mut self,
byte1: u8,
remaining_len: usize
) -> Result<Packet, Error>
&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>
&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>
&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>
Implementors
impl<R> MqttRead for R where
R: ReadBytesExt + ?Sized,
[src]
R: ReadBytesExt + ?Sized,
Implement MattRead for every AsyncReadExt type (and hence AsyncRead type)