From 849d827486c75b2ab223d7b0e638dbb5b74d4d1d Mon Sep 17 00:00:00 2001 From: hozan23 Date: Thu, 9 Nov 2023 11:38:19 +0300 Subject: rename crates --- karyons_net/src/listener.rs | 39 --------------------------------------- 1 file changed, 39 deletions(-) delete mode 100644 karyons_net/src/listener.rs (limited to 'karyons_net/src/listener.rs') diff --git a/karyons_net/src/listener.rs b/karyons_net/src/listener.rs deleted file mode 100644 index 31a63ae..0000000 --- a/karyons_net/src/listener.rs +++ /dev/null @@ -1,39 +0,0 @@ -use crate::{Endpoint, Error, Result}; -use async_trait::async_trait; - -use crate::{ - transports::{tcp, unix}, - Conn, -}; - -/// Listener is a generic network listener. -#[async_trait] -pub trait Listener: Send + Sync { - fn local_endpoint(&self) -> Result; - async fn accept(&self) -> Result; -} - -/// Listens to the provided endpoint. -/// -/// it only supports `tcp4/6` and `unix`. -/// -/// #Example -/// -/// ``` -/// use karyons_net::{Endpoint, listen}; -/// -/// async { -/// let endpoint: Endpoint = "tcp://127.0.0.1:3000".parse().unwrap(); -/// -/// let listener = listen(&endpoint).await.unwrap(); -/// let conn = listener.accept().await.unwrap(); -/// }; -/// -/// ``` -pub async fn listen(endpoint: &Endpoint) -> Result> { - match endpoint { - Endpoint::Tcp(addr, port) => Ok(Box::new(tcp::listen_tcp(addr, port).await?)), - Endpoint::Unix(addr) => Ok(Box::new(unix::listen_unix(addr)?)), - _ => Err(Error::InvalidEndpoint(endpoint.to_string())), - } -} -- cgit v1.2.3