Function rumqttc_async_std::read[][src]

pub fn read(stream: &mut BytesMut, max_size: usize) -> Result<Packet, Error>

Reads a stream of bytes and extracts next MQTT packet out of it