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()