fix: v5 doesn't write outgoing packets onto network

#825 (comment)
bytebeamio · Apr 7, 2024 · 8ac81cb · 8ac81cb
1 parent af55848
commit 8ac81cb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/rumqttc/src/v5/eventloop.rs b/rumqttc/src/v5/eventloop.rs
@@ -209,7 +209,9 @@ impl EventLoop {
                 self.options.pending_throttle
             ), if !self.pending.is_empty() || (!inflight_full && !collision) => match o {
                 Ok(request) => {
-                    self.state.handle_outgoing_packet(request)?;
+                    if let Some(outgoing) = self.state.handle_outgoing_packet(request)? {
+                        network.write(outgoing).await?;
+                    }
                     network.flush().await?;
                     Ok(self.state.events.pop_front().unwrap())
                 }