* fix logic but in this pr

* log errors properlly in event loop

Author: amokfa

rumqttc/src/eventloop.rs

@@ -161,6 +161,7 @@ impl EventLoop {
         match self.select().await {
             Ok(v) => Ok(v),
             Err(e) => {
+                log::error!("connection error : {e}");
                 self.clean();
                 Err(e)
             }

rumqttc/src/state.rs

@@ -323,7 +323,7 @@ impl MqttState {
     /// Adds next packet identifier to QoS 1 and 2 publish packets and returns
     /// it buy wrapping publish in packet
     fn outgoing_publish(&mut self, mut publish: Publish) -> Result<Option<Packet>, StateError> {
-        if publish.qos != QoS::AtMostOnce || publish.pkid > self.max_inflight {
+        if publish.qos != QoS::AtMostOnce && publish.pkid <= self.max_inflight {
             if publish.pkid == 0 {
                 publish.pkid = self.next_pkid();
             }