From 5dd15e30321046bc0401e22a09112545bf731b18 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Marcel=20M=C3=BCller?= Date: Thu, 21 Mar 2024 13:31:12 +0100 Subject: Implement MPubrec::write MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Marcel Müller --- mqtt-format/src/v5/packets/pubrec.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/mqtt-format/src/v5/packets/pubrec.rs b/mqtt-format/src/v5/packets/pubrec.rs index 2d7c984..42a5428 100644 --- a/mqtt-format/src/v5/packets/pubrec.rs +++ b/mqtt-format/src/v5/packets/pubrec.rs @@ -10,6 +10,8 @@ use winnow::Parser; use crate::v5::variable_header::PacketIdentifier; use crate::v5::variable_header::ReasonString; use crate::v5::variable_header::UserProperties; +use crate::v5::write::WResult; +use crate::v5::write::WriteMqttPacket; use crate::v5::MResult; crate::v5::reason_code::make_combined_reason_code! { @@ -61,4 +63,10 @@ impl<'i> MPubrec<'i> { }) .parse_next(input) } + + pub async fn write(&self, buffer: &mut W) -> WResult { + self.packet_identifier.write(buffer).await?; + self.reason.write(buffer).await?; + self.properties.write(buffer).await + } } -- cgit v1.2.3