From 76e952830302271e07a4be9df6dfaa1c11e3e675 Mon Sep 17 00:00:00 2001 From: hozan23 Date: Wed, 13 Mar 2024 03:35:09 +0100 Subject: net: pass `Endpoint` to dial and listen functions --- net/src/transports/udp.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'net/src/transports/udp.rs') diff --git a/net/src/transports/udp.rs b/net/src/transports/udp.rs index a8b505c..991b1fd 100644 --- a/net/src/transports/udp.rs +++ b/net/src/transports/udp.rs @@ -5,7 +5,7 @@ use smol::net::UdpSocket; use crate::{ connection::{Connection, ToConn}, - endpoint::{Addr, Endpoint, Port}, + endpoint::Endpoint, Error, Result, }; @@ -57,19 +57,19 @@ impl Connection for UdpConn { } /// Connects to the given UDP address and port. -pub async fn dial_udp(addr: &Addr, port: &Port) -> Result { - let address = format!("{}:{}", addr, port); +pub async fn dial_udp(endpoint: &Endpoint) -> Result { + let addr = SocketAddr::try_from(endpoint.clone())?; // Let the operating system assign an available port to this socket let conn = UdpSocket::bind("[::]:0").await?; - conn.connect(address).await?; + conn.connect(addr).await?; Ok(UdpConn::new(conn)) } /// Listens on the given UDP address and port. -pub async fn listen_udp(addr: &Addr, port: &Port) -> Result { - let address = format!("{}:{}", addr, port); - let conn = UdpSocket::bind(address).await?; +pub async fn listen_udp(endpoint: &Endpoint) -> Result { + let addr = SocketAddr::try_from(endpoint.clone())?; + let conn = UdpSocket::bind(addr).await?; let udp_conn = UdpConn::new(conn); Ok(udp_conn) } -- cgit v1.2.3