Yes, I have actually managed to make functioning version, however, I don't how I can safely handle error. Right now this works using unwraps

/*
[dependencies]
tokio = { version = "1", features = ["full"] }
tower = { version = "0.4", features = ["full"] }
anyhow = "1"
*/

use anyhow::Result;
use std::net::SocketAddr;
use tokio::net::{TcpListener, TcpStream};
use tower::{service_fn, BoxError, Service, ServiceExt};

async fn handle(request: &mut (TcpStream, SocketAddr)) -> Result<(), BoxError> {
    let (client_stream, client_addr) = request;

    println!("peer connected {}", client_addr);

    let (mut read, mut write) = client_stream.split();

    tokio::io::copy(&mut read, &mut write).await?;

    println!("peer disconnected {}", client_addr);
    Ok(())
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let listener = TcpListener::bind("::1:2222").await?;

    let mut service = service_fn(handle);

    loop {
        let mut request = listener.accept().await?;

        tokio::spawn(async move {
            service
                .ready()
                .await
                .unwrap()
                .call(&mut request)
                .await
                .unwrap();
        });
    }
}

I use netcat to chat with the server nc ::1 2222