tokio_echo.rs

// Super simple TCP echo server using Tokio
// basically a couple tutorials spliced together by DM Futcher (github.com/dmfutcher)

use tokio::net::{TcpListener, TcpStream};
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};

async fn process_connection(mut stream : TcpStream) {
    let (reader, mut writer) = stream.split();
    let buf = BufReader::new(reader);
    let mut lines = buf.lines();

    while let Some(line) = lines.next_line().await.unwrap() {
        println!("{}", line);
        writer.write(line.as_bytes()).await.unwrap();
    }
}

#[tokio::main]
pub async fn main() {
    let listener = TcpListener::bind("127.0.0.1:8099").await.unwrap();

    loop {
        let (socket, _) = listener.accept().await.unwrap();
        tokio::spawn(async move {
            process_connection(socket).await;
        });
    }
}