diff --git a/src/mqtt.rs b/src/mqtt.rs index faaca87..e162dc9 100644 --- a/src/mqtt.rs +++ b/src/mqtt.rs @@ -54,13 +54,12 @@ impl MQTT { mqttoptions.set_keep_alive(Duration::from_secs(5)); let (client, eventloop) = AsyncClient::new(mqttoptions, 1); - let mqtt = MQTT { - config: config, - client: client, - eventloop: eventloop, - }; - mqtt + MQTT { + config, + client, + eventloop, + } } pub async fn subscribe(&mut self, callback: F) -> Result<()> {