From a862637a7744e73c0fef8ebc18e457d026b5af31 Mon Sep 17 00:00:00 2001
From: Ondrej Babec <ond.babec@gmail.com>
Date: Fri, 25 Feb 2022 16:49:48 +0100
Subject: [PATCH] Custom scope

---
 src/client/client_v5.rs | 14 ++++++++------
 src/main.rs             |  2 +-
 2 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/src/client/client_v5.rs b/src/client/client_v5.rs
index 34198c2..d1ddf79 100644
--- a/src/client/client_v5.rs
+++ b/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
 
diff --git a/src/main.rs b/src/main.rs
index dea981a..0e09864 100644
--- a/src/main.rs
+++ b/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()