Custom scope

src/client/client_v5.rs

@@ -34,16 +34,18 @@ where
         self.network_driver.send(self.buffer, len).await ?;
 
         //connack
-        let connack = {
+        {
             self.receive().await ?;
-            let mut packet = ConnackPacket::new();
+            let mut packet = ConnackPacket::<5>::new();
             packet.decode(&mut BuffReader::new(self.buffer));
-            packet
+
+
+            if packet.connect_reason_code != 0x00 {
+                todo!();
+            }
         };
 
-        if connack.connect_reason_code != 0x00 {
-            todo!();
-        }
+
 
         // publish
 

src/main.rs

@@ -7,7 +7,7 @@ use rust_mqtt::packet::subscription_packet::SubscriptionPacket;
 use rust_mqtt::tokio_network::TokioNetwork;
 
 #[tokio::main]
-fn main() {
+async fn main() {
     env_logger::builder()
         .filter_level(log::LevelFilter::Info)
         .format_timestamp_nanos()