Merge pull request #278 from matthiasbeyer/some-clippy-fixes

Some clippy fixes

2 files changed, 2 insertions, 5 deletions

diff --git a/src/client/receive.rs b/src/client/receive.rs
index 4d73cd5..7f8db18 100644
--- a/src/client/receive.rs
+++ b/src/client/receive.rs
@@ -7,7 +7,6 @@
 use std::sync::Arc;
 
 use futures::lock::Mutex;
-use futures::SinkExt;
 use futures::StreamExt;
 use tokio_util::codec::FramedRead;
 use tracing::Instrument;
@@ -88,7 +87,7 @@ pub(super) async fn handle_background_receiving(
     }
 
     tracing::debug!("Finished processing, returning reader");
-    if let Err(conn_read) = conn_read_sender.send(conn_read) {
+    if let Err(_conn_read) = conn_read_sender.send(conn_read) {
         tracing::error!("Failed to return reader");
         todo!()
     }
diff --git a/src/client/send.rs b/src/client/send.rs
index c7748ca..1883a64 100644
--- a/src/client/send.rs
+++ b/src/client/send.rs
@@ -6,9 +6,7 @@
 
 use std::collections::HashMap;
 use std::collections::VecDeque;
-use std::num::NonZeroU16;
 
-use futures::SinkExt;
 use mqtt_format::v5::integers::VARIABLE_INTEGER_MAX;
 use mqtt_format::v5::packets::publish::MPublish;
 use tracing::Instrument;
@@ -312,7 +310,7 @@ pub struct Published {
 impl Published {
     pub async fn acknowledged(self) {
         match self.recv {
-            PublishedReceiver::None => return,
+            PublishedReceiver::None => (),
             PublishedReceiver::Once(qos1) => {
                 qos1.acknowledged().await;
             }