leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Remove pin<box further

Browse source
This commit is contained in:
Igor Katson 2024-02-27 08:17:15 +00:00
parent a001bb8c97
commit 3cecb1a4c3
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

5
Cargo.toml
View file

@ -10,8 +10,9 @@ members = [
"crates/librqbit_core", "crates/librqbit_core",
"crates/peer_binary_protocol", "crates/peer_binary_protocol",
"crates/dht", "crates/dht",
"crates/upnp" "crates/upnp",
, "crates/tracker_comms"] "crates/tracker_comms",
]
[profile.dev] [profile.dev]
panic = "abort" panic = "abort"

5
crates/tracker_comms/src/tracker_comms.rs
View file

@ -1,14 +1,13 @@
use std::net::SocketAddr; use std::net::SocketAddr;
use std::pin::Pin;
use std::sync::Arc; use std::sync::Arc;
use std::time::Duration; use std::time::Duration;
use anyhow::bail; use anyhow::bail;
use anyhow::Context; use anyhow::Context;
use futures::future::Either; use futures::future::Either;
use futures::stream::BoxStream;
use futures::stream::FuturesUnordered; use futures::stream::FuturesUnordered;
use futures::FutureExt; use futures::FutureExt;
use futures::Stream;
use futures::StreamExt; use futures::StreamExt;
use tracing::debug; use tracing::debug;
use tracing::error_span; use tracing::error_span;
@ -67,7 +66,7 @@ impl TrackerComms {
stats: Box<dyn TorrentStatsProvider>, stats: Box<dyn TorrentStatsProvider>,
force_interval: Option<Duration>, force_interval: Option<Duration>,
tcp_listen_port: Option<u16>, tcp_listen_port: Option<u16>,
) -> Option<Pin<Box<dyn Stream<Item = SocketAddr> + Send + 'static>>> { ) -> Option<BoxStream<'static, SocketAddr>> {
let trackers = trackers let trackers = trackers
.into_iter() .into_iter()
.filter_map(|t| match Url::parse(&t) { .filter_map(|t| match Url::parse(&t) {