summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2024-03-21 13:37:31 +0100
committerMatthias Beyer <mail@beyermatthias.de>2024-03-21 13:42:15 +0100
commitfb247511d98cfed9fef3d14da7559fc3c4d2518d (patch)
treead106317686c9dcd288c59cdd50747bc8e44f74e
parent08fbcf5e5df299e907e9e5fb982de0d8f5644985 (diff)
Implement MDisconnect::write
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
-rw-r--r--mqtt-format/src/v5/packets/disconnect.rs7
1 files changed, 7 insertions, 0 deletions
diff --git a/mqtt-format/src/v5/packets/disconnect.rs b/mqtt-format/src/v5/packets/disconnect.rs
index 7dd6cc5..bb07435 100644
--- a/mqtt-format/src/v5/packets/disconnect.rs
+++ b/mqtt-format/src/v5/packets/disconnect.rs
@@ -12,6 +12,8 @@ use crate::v5::variable_header::ReasonString;
use crate::v5::variable_header::ServerReference;
use crate::v5::variable_header::SessionExpiryInterval;
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! {
@@ -87,4 +89,9 @@ impl<'i> MDisconnect<'i> {
})
.parse_next(input)
}
+
+ pub async fn write<W: WriteMqttPacket>(&self, buffer: &mut W) -> WResult<W> {
+ self.reason_code.write(buffer).await?;
+ self.properties.write(buffer).await
+ }
}