trillium-async-std 0.5.0

async-std runtime adapter for trillium.rs
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use crate::{AsyncStdRuntime, AsyncStdTransport, AsyncStdUdpSocket};
use async_std::net::{TcpListener, TcpStream};
use std::io::Result;
use trillium::Info;
use trillium_server_common::Server;

/// Tcp-only Trillium server for Async-std
#[derive(Debug)]
pub struct AsyncStdServer(TcpListener);
impl From<TcpListener> for AsyncStdServer {
    fn from(value: TcpListener) -> Self {
        Self(value)
    }
}
impl From<std::net::TcpListener> for AsyncStdServer {
    fn from(value: std::net::TcpListener) -> Self {
        TcpListener::from(value).into()
    }
}

impl Server for AsyncStdServer {
    type Runtime = AsyncStdRuntime;
    type Transport = AsyncStdTransport<TcpStream>;
    type UdpTransport = AsyncStdUdpSocket;

    async fn accept(&mut self) -> Result<Self::Transport> {
        self.0.accept().await.map(|(t, _)| t.into())
    }

    fn from_tcp(tcp: std::net::TcpListener) -> Self {
        Self(tcp.into())
    }

    fn init(&self, info: &mut Info) {
        if let Ok(socket_addr) = self.0.local_addr() {
            info.insert_shared_state(socket_addr);
        }
    }

    fn runtime() -> Self::Runtime {
        AsyncStdRuntime::default()
    }
}