trapeze 0.7.6

A rust implementation of ttrpc
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::io::Result as IoResult;

use async_trait::async_trait;
use tokio::net::{TcpListener, TcpStream};

use super::{Connection, Listener};

#[async_trait]
impl Listener for TcpListener {
    async fn accept(&mut self) -> IoResult<Box<dyn Connection>> {
        let (conn, _) = TcpListener::accept(self).await?;
        Ok(Box::new(conn))
    }
}

pub async fn bind(addr: impl AsRef<str>) -> IoResult<impl Listener> {
    TcpListener::bind(addr.as_ref()).await
}

pub async fn connect(addr: impl AsRef<str>) -> IoResult<impl Connection> {
    TcpStream::connect(addr.as_ref()).await
}