From bf08d6945489ffa6d8074d613fbce4e4624d1a93 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Marcel=20M=C3=BCller?= Date: Thu, 21 Mar 2024 13:50:22 +0100 Subject: fixup! Implement MUnsubscribe::write --- mqtt-format/src/v5/packets/unsubscribe.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/mqtt-format/src/v5/packets/unsubscribe.rs b/mqtt-format/src/v5/packets/unsubscribe.rs index aa02bac..399ec86 100644 --- a/mqtt-format/src/v5/packets/unsubscribe.rs +++ b/mqtt-format/src/v5/packets/unsubscribe.rs @@ -105,6 +105,7 @@ impl<'i> Unsubscription<'i> { }) .parse_next(input) } + pub async fn write(&self, buffer: &mut W) -> WResult { write_string(buffer, self.topic_filter).await } @@ -136,4 +137,10 @@ impl<'i> MUnsubscribe<'i> { }) .parse_next(input) } + + pub async fn write(&self, buffer: &mut W) -> WResult { + self.packet_identifier.write(buffer).await?; + self.properties.write(buffer).await?; + self.unsubscriptions.write(buffer).await + } } -- cgit v1.2.3