mqtt/packet/
pubrec.rs

1//! PUBREC
2
3use std::io::Read;
4
5use crate::control::variable_header::PacketIdentifier;
6use crate::control::{ControlType, FixedHeader, PacketType};
7use crate::packet::{DecodablePacket, PacketError};
8use crate::Decodable;
9
10/// `PUBREC` packet
11#[derive(Debug, Eq, PartialEq, Clone)]
12pub struct PubrecPacket {
13    fixed_header: FixedHeader,
14    packet_identifier: PacketIdentifier,
15}
16
17encodable_packet!(PubrecPacket(packet_identifier));
18
19impl PubrecPacket {
20    pub fn new(pkid: u16) -> PubrecPacket {
21        PubrecPacket {
22            fixed_header: FixedHeader::new(PacketType::with_default(ControlType::PublishReceived), 2),
23            packet_identifier: PacketIdentifier(pkid),
24        }
25    }
26
27    pub fn packet_identifier(&self) -> u16 {
28        self.packet_identifier.0
29    }
30
31    pub fn set_packet_identifier(&mut self, pkid: u16) {
32        self.packet_identifier.0 = pkid;
33    }
34}
35
36impl DecodablePacket for PubrecPacket {
37    type DecodePacketError = std::convert::Infallible;
38
39    fn decode_packet<R: Read>(reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>> {
40        let packet_identifier: PacketIdentifier = PacketIdentifier::decode(reader)?;
41        Ok(PubrecPacket {
42            fixed_header,
43            packet_identifier,
44        })
45    }
46}
mqtt/packet/pubrec.rs

mqtt/packet/
pubrec.rs
