diff --git a/Cargo.toml b/Cargo.toml index 22f0267..70f255f 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -10,8 +10,9 @@ members = [ "crates/librqbit_core", "crates/peer_binary_protocol", "crates/dht", - "crates/upnp" -, "crates/tracker_comms"] + "crates/upnp", + "crates/tracker_comms", +] [profile.dev] panic = "abort" diff --git a/crates/tracker_comms/src/tracker_comms.rs b/crates/tracker_comms/src/tracker_comms.rs index cf675ba..d8b984a 100644 --- a/crates/tracker_comms/src/tracker_comms.rs +++ b/crates/tracker_comms/src/tracker_comms.rs @@ -1,14 +1,13 @@ use std::net::SocketAddr; -use std::pin::Pin; use std::sync::Arc; use std::time::Duration; use anyhow::bail; use anyhow::Context; use futures::future::Either; +use futures::stream::BoxStream; use futures::stream::FuturesUnordered; use futures::FutureExt; -use futures::Stream; use futures::StreamExt; use tracing::debug; use tracing::error_span; @@ -67,7 +66,7 @@ impl TrackerComms { stats: Box, force_interval: Option, tcp_listen_port: Option, - ) -> Option + Send + 'static>>> { + ) -> Option> { let trackers = trackers .into_iter() .filter_map(|t| match Url::parse(&t) {