Skip to content

Commit 009c680

Browse files
committed
fix after rebase
1 parent 51d7a05 commit 009c680

File tree

1 file changed

+10
-13
lines changed

1 file changed

+10
-13
lines changed

iroh-dns/src/discovery.rs

Lines changed: 10 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,11 @@ use std::sync::Arc;
22

33
use anyhow::Result;
44
use futures::{future::FutureExt, stream::BoxStream, StreamExt};
5-
use iroh_net::{discovery::{Discovery, DiscoveryItem}, key::SecretKey, AddrInfo, MagicEndpoint, NodeId};
5+
use iroh_net::{
6+
discovery::{Discovery, DiscoveryItem},
7+
key::SecretKey,
8+
AddrInfo, MagicEndpoint, NodeId,
9+
};
610
use tracing::warn;
711

812
use crate::publish::{self, Publisher};
@@ -47,26 +51,19 @@ impl Discovery for DnsDiscovery {
4751
}
4852
}
4953

50-
fn resolve(
51-
&self,
54+
fn resolve<'a>(
55+
&'a self,
5256
_ep: MagicEndpoint,
5357
node_id: NodeId,
54-
) -> Option<BoxStream<'static, Result<DiscoveryItem>>> {
55-
let resolver = self.resolver.clone();
58+
) -> Option<BoxStream<'a, Result<DiscoveryItem>>> {
5659
let fut = async move {
57-
let addr_info = resolver.resolve_node_by_id(node_id).await?;
60+
let addr_info = self.resolver.resolve_node_by_id(node_id).await?;
5861
Ok(DiscoveryItem {
5962
provenance: "iroh-dns",
6063
last_updated: None,
6164
addr_info,
6265
})
6366
};
64-
// let fut = fut.map_ok(|addr_info| DiscoveryItem {
65-
// provenance: "iroh-dns",
66-
// last_updated: None,
67-
// addr_info,
68-
// });
69-
let stream = fut.into_stream();
70-
Some(stream.boxed())
67+
Some(fut.into_stream().boxed())
7168
}
7269
}

0 commit comments

Comments
 (0)