We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c11c1f7 commit 1c70c41Copy full SHA for 1c70c41
crates/common/mqtt_channel/src/connection.rs
@@ -306,7 +306,7 @@ impl Connection {
306
// Wait for Err(MqttState(ConnectionAborted))
307
// to make sure the disconnect is effective
308
loop {
309
- if let Err(_) = event_loop.poll().await {
+ if (event_loop.poll().await).is_err() {
310
info!("MQTT connection closed");
311
break;
312
}
0 commit comments