如何在异步的情况下使用跨两个线程的TcpStream？

[dependencies]
tokio = { version = "1", features = ["full"] }
tokio-util = "0.6"

use std::net::TcpListener;
use tokio::net::TcpStream;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::task;

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

    loop {
        let (stream, _) = listener.accept().await.unwrap();

        // 将TcpStream移动到新的任务中
        task::spawn(async move {
            let mut stream = stream;

            // 读取数据
            let mut buffer = [0; 1024];
            let n = stream.read(&mut buffer).await.unwrap();
            let request = String::from_utf8_lossy(&buffer[..n]);
            println!("Received request: {}", request);

            // 处理数据
            let response = process_request(request);

            // 发送响应
            stream.write_all(response.as_bytes()).await.unwrap();
        });
    }
}

fn process_request(request: String) -> String {
    // 处理请求的逻辑
    // ...

    // 返回响应
    "Hello, World!".to_string()
}