推荐你个学习项目把，用Rust实现的redis，网络模型，实现了io多线程处理，命令单线程处理，这个项目够你学tokio了，包括怎么处理数据流，还有用一些异步消息管道的操作。

https://github.com/kwsc98/kedis-rust

试试这种codec的方式合适吗，我也是新手，感觉这个用起来挺舒服

https://github.com/berkowski/tokio-serial/blob/master/examples/serial_println.rs

先看官方文档

你说的是这种吗

use tokio_stream::StreamExt;
#[tokio::main]
async fn main(){
    let s = async_stream::stream! {
        for i in 0..3 {
            yield i;
        }
    };
    tokio::pin!(s);
    let mut s=s.map(|n|n+1);
    while let Some(value) = s.next().await {
        println!("{}", value);
    }
}