resty 0.1.3

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
21
22
23
24

use std::{marker::PhantomData, net::SocketAddrV4};

use smol::net::{AsyncToSocketAddrs, TcpListener, TcpStream};

pub struct TcpScocket<A = SocketAddrV4>(TcpListener, PhantomData<A>);

impl<A: AsyncToSocketAddrs + Send + Sync> super::Socket for TcpScocket<A> {
    type Error = smol::io::Error;
    type Address = A;
    type Stream = TcpStream;

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

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

        Ok(stream)
    }
}