blob: 31a63aee727ee9334dc33904fedfa6f2cdde096d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
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<Endpoint>;
async fn accept(&self) -> Result<Conn>;
}
/// 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<Box<dyn Listener>> {
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())),
}
}
|
