wip

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.12.7] - 2023-11-04
+
+* Fix v5::Subscribe packet encoding
+
 ## [0.12.6] - 2023-10-31
 
 * Send server ConnectAck without io flushing

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-mqtt"
-version = "0.12.6"
+version = "0.12.7"
 authors = ["ntex contributors <[email protected]>"]
 description = "Client and Server framework for MQTT v5 and v3.1.1 protocols"
 documentation = "https://docs.rs/ntex-mqtt"

src/v5/codec/packet/subscribe.rs

@@ -334,6 +334,7 @@ mod tests {
         let size = pkt.encoded_size(99999);
         let mut buf = BytesMut::with_capacity(size);
         pkt.encode(&mut buf, size as u32).unwrap();
+        assert_eq!(buf.len(), size);
         assert_eq!(pkt, Subscribe::decode(&mut buf.freeze()).unwrap());
     }