cargo fmt / clippy / fix

crates/dht/examples/dht.rs

@@ -2,7 +2,7 @@ use std::time::Duration;
 
 use anyhow::Context;
 use librqbit_core::magnet::Magnet;
-use librqbit_dht::{Dht, DhtBuilder};
+use librqbit_dht::DhtBuilder;
 use tokio_stream::StreamExt;
 use tracing::info;
 

crates/dht/src/dht.rs

@@ -1,5 +1,4 @@
 use std::{
-    f32::consts::E,
     net::SocketAddr,
     sync::{
         atomic::{AtomicU16, Ordering},
@@ -19,9 +18,9 @@ use crate::{
 };
 use anyhow::Context;
 use backoff::{backoff::Backoff, ExponentialBackoffBuilder};
-use bencode::{ByteBuf, ByteString};
+use bencode::ByteString;
 use dashmap::DashMap;
-use futures::{future::join_all, stream::FuturesUnordered, Stream, StreamExt, TryFutureExt};
+use futures::{stream::FuturesUnordered, Stream, StreamExt};
 use indexmap::IndexSet;
 use leaky_bucket::RateLimiter;
 use librqbit_core::{id20::Id20, peer_id::generate_peer_id, spawn_utils::spawn};

crates/dht/src/routing_table.rs

@@ -1,7 +1,4 @@
-use std::{
-    net::SocketAddr,
-    time::{Duration, Instant},
-};
+use std::{net::SocketAddr, time::Instant};
 
 use librqbit_core::id20::Id20;
 use serde::{ser::SerializeMap, Deserialize, Serialize};

crates/librqbit/src/dht_utils.rs

@@ -86,7 +86,7 @@ pub async fn read_metainfo_from_peer_receiver<A: Stream<Item = SocketAddr> + Unp
 
 #[cfg(test)]
 mod tests {
-    use dht::{Dht, DhtBuilder, Id20};
+    use dht::{DhtBuilder, Id20};
     use librqbit_core::peer_id::generate_peer_id;
 
     use super::*;