fix write unsubcribe

Author: GunnarMorrigan

mqrstt/src/packets/mod.rs

@@ -509,6 +509,9 @@ mod tests {
 
         let wire_len = packet.wire_len();
         assert_eq!(wire_len, buffer.len());
+        dbg!(wire_len);
+        let a: Vec<_> = buffer.iter().map(|f| *f as u16).collect();
+        println!("{:?}", a);
 
         let res1 = Packet::read(&mut buffer).unwrap();
 
@@ -598,9 +601,11 @@ mod tests {
         use crate::packets::WireLength;
 
         let mut buffer = Vec::with_capacity(1000);
-        packet.async_write(&mut buffer).await.unwrap();
+        let res = packet.async_write(&mut buffer).await.unwrap();
 
         let wire_len = packet.wire_len();
+
+        assert_eq!(res, wire_len);
         assert_eq!(wire_len, buffer.len());
 
         let mut buf = buffer.as_slice();

mqrstt/src/packets/unsubscribe/mod.rs

@@ -110,6 +110,8 @@ where
         let mut total_written_bytes = 2;
         stream.write_u16(self.packet_identifier).await?;
 
+        total_written_bytes += self.properties.async_write(stream).await?;
+
         for topic in &self.topics {
             total_written_bytes += topic.async_write(stream).await?;
         }