mqtt/packet/
pubcomp.rs

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

mqtt/packet/
pubcomp.rs
