试试这种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);
    }
}