From 91c99a272f84c2ed9620d6964fbd510b1cc84b4d Mon Sep 17 00:00:00 2001 From: Igor Katson Date: Tue, 28 Nov 2023 11:35:28 +0000 Subject: [PATCH] cargo fmt / clippy / fix --- crates/dht/examples/dht.rs | 2 +- crates/dht/src/dht.rs | 5 ++--- crates/dht/src/routing_table.rs | 5 +---- crates/librqbit/src/dht_utils.rs | 2 +- 4 files changed, 5 insertions(+), 9 deletions(-) diff --git a/crates/dht/examples/dht.rs b/crates/dht/examples/dht.rs index 38c5342..dc0cc4f 100644 --- a/crates/dht/examples/dht.rs +++ b/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; diff --git a/crates/dht/src/dht.rs b/crates/dht/src/dht.rs index 7ffc9b8..3c42f1c 100644 --- a/crates/dht/src/dht.rs +++ b/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}; diff --git a/crates/dht/src/routing_table.rs b/crates/dht/src/routing_table.rs index fce5c14..965a414 100644 --- a/crates/dht/src/routing_table.rs +++ b/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}; diff --git a/crates/librqbit/src/dht_utils.rs b/crates/librqbit/src/dht_utils.rs index fb5b339..69aacba 100644 --- a/crates/librqbit/src/dht_utils.rs +++ b/crates/librqbit/src/dht_utils.rs @@ -86,7 +86,7 @@ pub async fn read_metainfo_from_peer_receiver + Unp #[cfg(test)] mod tests { - use dht::{Dht, DhtBuilder, Id20}; + use dht::{DhtBuilder, Id20}; use librqbit_core::peer_id::generate_peer_id; use super::*;