mqtt/packet/
puback.rs

1//! PUBACK
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/// `PUBACK` packet
11#[derive(Debug, Eq, PartialEq, Clone)]
12pub struct PubackPacket {
13    fixed_header: FixedHeader,
14    packet_identifier: PacketIdentifier,
15}
16
17encodable_packet!(PubackPacket(packet_identifier));
18
19impl PubackPacket {
20    pub fn new(pkid: u16) -> PubackPacket {
21        PubackPacket {
22            fixed_header: FixedHeader::new(PacketType::with_default(ControlType::PublishAcknowledgement), 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 PubackPacket {
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(PubackPacket {
42            fixed_header,
43            packet_identifier,
44        })
45    }
46}
mqtt/packet/puback.rs

mqtt/packet/
puback.rs
