tokiomain.rs

#[tokio::main]
async fn main() -> Result<()> {
    let addr = "127.0.0.1:8080".parse::<SocketAddr>().unwrap();
    let listener = TcpListener::bind(addr).await.unwrap();
    let mut ring = IoUring::new(256)?;

    loop {
        let (stream, _) = listener.accept().await?;
        handle_client(stream, &mut ring).await?;
    }
}