resty 0.1.2

A fast, concurrent and multi-threadable REST framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::{marker::PhantomData, path::Path};

use smol::net::unix::{UnixListener, UnixStream};

pub struct UnixSocket<P = &'static str>(UnixListener, PhantomData<P>);

impl<P: AsRef<Path> + Send + Sync> super::Socket for UnixSocket<P> {
    type Error = smol::io::Error;
    type Address = P;
    type Stream = UnixStream;

    async fn bind(addr: Self::Address) -> Result<Box<Self>, Self::Error> {
        UnixListener::bind(addr).map(|listener| Box::new(UnixSocket(listener, PhantomData)))
    }

    async fn accept(&self) -> Result<Self::Stream, Self::Error> {
        let (stream, ..) = self.0.accept().await?;
        Ok(stream)
    }
}