我最近一直在玩Rust，我试图用时雄运行async命令。**我的目标是实时读取stdout/err，并能够在需要时向进程传递消息。**我不依赖时雄，如果有更好的方法，请建议。
我使用时雄process：：Command创建一个子进程，然后将其转换为流并从中读取，但如果进程是连续的，我就不会得到stdout/err。下面是我一直在玩的东西（使用python作为持续运行的进程）：

use std::process::Stdio;
    use tokio_stream::StreamExt;
    use tokio_util::codec::{FramedRead, LinesCodec, FramedWrite};

    let mut process = tokio::process::Command::new("sh")
        .arg("-c")
        .arg("python3")
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .stdin(Stdio::piped())
        .spawn()
        .unwrap();

    let stdout = FramedRead::new(process.stdout.take().unwrap(), LinesCodec::new())
        .map(|data| data.expect("fail on out!"));

    let stderr = FramedRead::new(process.stderr.take().unwrap(), LinesCodec::new())
        .map(|data| data.expect("fail on err!"));

    let mut stream = stdout.chain(stderr);

    while let Some(msg) = stream.next().await {
        println!("{:?}", msg);
    }

我还尝试等待进程的输出，在那里我得到空的stdout和stderr -不完全知道为什么。当我在不使用管道stderr/out/in的情况下执行进程时，我从python获得了通常的初始响应。
引用的Cargo.toml依赖项：

tokio = {version="1.26", features = ["rt", "macros", "rt-multi-thread", "fs", "process", "io-std", "io-util"]}
tokio-util = { version="0.7.7", features = ["codec", "io"]}
tokio-stream = "0.1.12"