pub fn decode_mqtt(
bytes: &mut BytesMut,
protocol_version: ProtocolVersion,
) -> Result<Option<Packet>, DecodeError>
pub fn decode_mqtt(
bytes: &mut BytesMut,
protocol_version: ProtocolVersion,
) -> Result<Option<Packet>, DecodeError>