diff options
| -rw-r--r-- | mqtt-format/src/v5/packets/unsubscribe.rs | 7 |
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 + } } |