berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

fix: fix Trust DNS leftovers

This commit is contained in:
Yuki Okushi 2025-09-23 09:54:49 +09:00
parent 5904bd2997
commit 60719e23d2
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
actix-tls/src/connect/resolve.rs
View File

@ -13,11 +13,11 @@ use futures_core::future::LocalBoxFuture;
/// use actix_tls::connect::{Resolve, Resolver}; /// use actix_tls::connect::{Resolve, Resolver};
/// use futures_util::future::LocalBoxFuture; /// use futures_util::future::LocalBoxFuture;
/// ///
/// // use trust-dns async tokio resolver /// // use Hickory DNS tokio resolver
/// use trust_dns_resolver::TokioAsyncResolver; /// use hickory_resolver::TokioResolver;
/// ///
/// struct MyResolver { /// struct MyResolver {
/// trust_dns: TokioAsyncResolver, /// hickory_dns: TokioResolver,
/// }; /// };
/// ///
/// // impl Resolve trait and convert given host address str and port to SocketAddr. /// // impl Resolve trait and convert given host address str and port to SocketAddr.
@ -29,7 +29,7 @@ use futures_core::future::LocalBoxFuture;
/// ) -> LocalBoxFuture<'a, Result<Vec<SocketAddr>, Box<dyn std::error::Error>>> { /// ) -> LocalBoxFuture<'a, Result<Vec<SocketAddr>, Box<dyn std::error::Error>>> {
/// Box::pin(async move { /// Box::pin(async move {
/// let res = self /// let res = self
/// .trust_dns /// .hickory_dns
/// .lookup_ip(host) /// .lookup_ip(host)
/// .await? /// .await?
/// .iter() /// .iter()
@ -41,7 +41,7 @@ use futures_core::future::LocalBoxFuture;
/// } /// }
/// ///
/// let my_resolver = MyResolver { /// let my_resolver = MyResolver {
/// trust_dns: TokioAsyncResolver::tokio_from_system_conf().unwrap(), /// hickory_dns: TokioResolver::builder_tokio().unwrap().build(),
/// }; /// };
/// ///
/// // wrap custom resolver /// // wrap custom resolver

6
actix-tls/tests/test_resolvers.rs
View File

@ -55,7 +55,7 @@ async fn custom_resolver_connect() {
let srv = TestServer::start(|| fn_service(|_io: TcpStream| async { Ok::<_, io::Error>(()) })); let srv = TestServer::start(|| fn_service(|_io: TcpStream| async { Ok::<_, io::Error>(()) }));
struct MyResolver { struct MyResolver {
trust_dns: TokioResolver, hickory_dns: TokioResolver,
} }
impl Resolve for MyResolver { impl Resolve for MyResolver {
@ -66,7 +66,7 @@ async fn custom_resolver_connect() {
) -> LocalBoxFuture<'a, Result<Vec<SocketAddr>, Box<dyn std::error::Error>>> { ) -> LocalBoxFuture<'a, Result<Vec<SocketAddr>, Box<dyn std::error::Error>>> {
Box::pin(async move { Box::pin(async move {
let res = self let res = self
.trust_dns .hickory_dns
.lookup_ip(host) .lookup_ip(host)
.await? .await?
.iter() .iter()
@ -78,7 +78,7 @@ async fn custom_resolver_connect() {
} }
let resolver = MyResolver { let resolver = MyResolver {
trust_dns: TokioResolver::builder_tokio().unwrap().build(), hickory_dns: TokioResolver::builder_tokio().unwrap().build(),
}; };
let factory = connector_factory(Resolver::custom(resolver)); let factory = connector_factory(Resolver::custom(resolver));