diff options
author | Marcel Müller <neikos@neikos.email> | 2024-04-05 11:02:16 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-04-05 11:02:16 +0200 |
commit | ce9f648cbb5c65cc049ba0f6efa75eb5b9b11329 (patch) | |
tree | 9c31605ed2f51c6a730a891c87bc9804c1cd60fe | |
parent | 5ddd8ae1dba01b419163b9a616246460fc7def8f (diff) | |
parent | 00bbd4ef81195437649b70a68d79cd7223c88c12 (diff) |
Merge pull request #278 from matthiasbeyer/some-clippy-fixes
Some clippy fixes
-rw-r--r-- | src/client/receive.rs | 3 | ||||
-rw-r--r-- | src/client/send.rs | 4 |
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; } |