diff --git a/src/mqtt.rs b/src/mqtt.rs index e162dc9..85a9a05 100644 --- a/src/mqtt.rs +++ b/src/mqtt.rs @@ -70,13 +70,10 @@ impl MQTT { let notification = self.eventloop.poll().await?; debug!("Notification = {:?}", notification); - match notification { - Event::Incoming(Incoming::Publish(p)) => { - let msg: StatusMessage = serde_json::from_slice(p.payload.as_ref())?; - info!("Message: {:?}", msg); - callback(msg); - }, - _ => (), + if let Event::Incoming(Incoming::Publish(p)) = notification { + let msg: StatusMessage = serde_json::from_slice(p.payload.as_ref())?; + info!("Message: {:?}", msg); + callback(msg); } }