summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2024-04-05 07:59:14 +0200
committerMatthias Beyer <mail@beyermatthias.de>2024-04-05 07:59:14 +0200
commite8a083ad0869c8c647cf6d139acc2039a99fe0b8 (patch)
tree2d38efce0252afd298abbb3373f4edae304e8c75
parent5ddd8ae1dba01b419163b9a616246460fc7def8f (diff)
Fix clippy: Remove unused stuff
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
-rw-r--r--src/client/receive.rs3
-rw-r--r--src/client/send.rs2
2 files changed, 1 insertions, 4 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..ac622cc 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;