diff --git a/pallas-network/src/facades.rs b/pallas-network/src/facades.rs index 2b3c508b..cc834d94 100644 --- a/pallas-network/src/facades.rs +++ b/pallas-network/src/facades.rs @@ -374,11 +374,8 @@ impl NodeServer { } } - pub async fn accept( - listener: impl AsRef + Send + 'static, - magic: u64, - ) -> Result { - let (bearer, address) = Bearer::accept_unix(listener.as_ref()) + pub async fn accept(listener: &UnixListener, magic: u64) -> Result { + let (bearer, address) = Bearer::accept_unix(listener) .await .map_err(Error::ConnectFailure)?; diff --git a/pallas-network/tests/protocols.rs b/pallas-network/tests/protocols.rs index 3984d3a0..436f07f3 100644 --- a/pallas-network/tests/protocols.rs +++ b/pallas-network/tests/protocols.rs @@ -1,6 +1,5 @@ use std::fs; use std::net::{Ipv4Addr, SocketAddrV4}; -use std::sync::Arc; use std::time::Duration; use pallas_codec::utils::{AnyCbor, AnyUInt, KeyValuePairs, TagWrap}; @@ -468,9 +467,9 @@ pub async fn local_state_query_server_and_client_happy_path() { fs::remove_file(socket_path).unwrap(); } - let listener = Arc::new(UnixListener::bind(socket_path).unwrap()); + let listener = UnixListener::bind(socket_path).unwrap(); - let mut server = pallas_network::facades::NodeServer::accept(listener, 0) + let mut server = pallas_network::facades::NodeServer::accept(&listener, 0) .await .unwrap();