diff --git a/src/handlers/mod.rs b/src/handlers/mod.rs index af9ceb6b..627f0c0d 100644 --- a/src/handlers/mod.rs +++ b/src/handlers/mod.rs @@ -25,7 +25,7 @@ pub struct MqttClient { impl MqttClient { pub fn new(sender: tokio::sync::mpsc::Sender) -> Self { - MqttClient { sender: sender } + MqttClient { sender } } } @@ -34,10 +34,7 @@ impl TransferClient for MqttClient { async fn send(&self, value: Value) -> Result { let (tx, rx) = oneshot::channel(); - let command = Command::Send { - value: value, - resp: tx, - }; + let command = Command::Send { value, resp: tx }; self.sender.send(command).await.map_err(|e| { log::error!("{:?}", e.to_string());