ruchei 0.1.2

Utilities for working with many streams
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Per-connection [`ruchei::echo::buffered`]

use async_std::{net::TcpListener, task};
use ruchei::echo::buffered::EchoBuffered;

#[async_std::main]
async fn main() {
    let listener = TcpListener::bind("127.0.0.1:8080").await.unwrap();
    while let Ok((stream, _)) = listener.accept().await {
        task::spawn(async {
            async_tungstenite::accept_async(stream)
                .await
                .unwrap()
                .echo_buffered()
                .await
                .unwrap()
        });
    }
}