summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMarcel Müller <neikos@neikos.email>2024-03-21 13:50:22 +0100
committerMarcel Müller <neikos@neikos.email>2024-03-21 13:50:22 +0100
commitbf08d6945489ffa6d8074d613fbce4e4624d1a93 (patch)
tree5c1e37183bc14495cbfe516b4599bf8ac0df083f
parentfd7d98c3e42f0a0984d7e18614ff029fd97f8cf3 (diff)
fixup! Implement MUnsubscribe::writefeature/add_v5_writing
-rw-r--r--mqtt-format/src/v5/packets/unsubscribe.rs7
1 files changed, 7 insertions, 0 deletions
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<W: WriteMqttPacket>(&self, buffer: &mut W) -> WResult<W> {
write_string(buffer, self.topic_filter).await
}
@@ -136,4 +137,10 @@ impl<'i> MUnsubscribe<'i> {
})
.parse_next(input)
}
+
+ pub async fn write<W: WriteMqttPacket>(&self, buffer: &mut W) -> WResult<W> {
+ self.packet_identifier.write(buffer).await?;
+ self.properties.write(buffer).await?;
+ self.unsubscriptions.write(buffer).await
+ }
}