如何在tokio中播放流

use tokio::runtime::Runtime;
use tokio::net::TcpStream;
use tokio::io::{AsyncReadExt, AsyncWriteExt};

async fn play_stream() -> Result<(), Box<dyn std::error::Error>> {
    // 建立与流的连接
    let mut stream = TcpStream::connect("127.0.0.1:8080").await?;

    // 从流中读取数据
    let mut buffer = [0; 1024];
    let n = stream.read(&mut buffer).await?;

    // 处理流的数据
    let data = &buffer[..n];
    println!("Received data: {:?}", data);

    // 将数据写入流中
    stream.write_all(data).await?;

    // 关闭连接
    drop(stream);

    Ok(())
}

fn main() {
    // 创建tokio运行时
    let rt = Runtime::new().unwrap();

    // 在tokio运行时中执行异步任务
    rt.block_on(async {
        if let Err(e) = play_stream().await {
            eprintln!("Error: {}", e);
        }
    });
}