三明治管生锈了怎么办？

Question

我想创建一个 Rust 程序，它通过管道从外部程序输入并通过管道吐到另一个外部程序，就像三明治一样。更具体地说，我尝试创建的玩具模型是“gzip -cd input | rust | gzip -c - > output”。

基本上，我知道如何做第一部分（管道输入），比如：

   let child = match Command::new("zcat")
        .args(&["input"])
        .stdout(Stdio::piped())
        .stderr(Stdio::null())
        .spawn();
   let filehand = BufReader::new(child.stdout.unwrap());
   for line in filehand.lines() {
       ...
   }

但我卡在了第二部分，我也不知道如何将两者拼凑起来。我知道 Perl 可以优雅地做到这一点：

open filehand_in, "gzip -cd input |";
open filehand_out, "| gzip -c - > output";
while ( <filehand_in> ) {
    # processing;
    print filehand_out ...;
}

优雅的意思是输入和输出的外部处理对主程序是透明的：你只需要将第一个管道视为stdin，将第二个管道视为stdout，没有什么可担心的。我想知道是否有人知道如何在 Rust 中实现类似的功能，谢谢。

Answer 1

你可以这样做：

use std::io::{BufRead, BufReader, Write};
use std::process::{Command, Stdio};

pub fn main() {
    let mut left_child = Command::new("/bin/ls")
        .stdout(Stdio::piped())
        .spawn()
        .expect("failed to execute child");

    let mut right_child = Command::new("/bin/cat")
        .stdin(Stdio::piped())
        .spawn()
        .expect("failed to execute child");

    // extra scope to ensure that left_in and right_out are closed after
    // copying all available data
    {
        let left_in = BufReader::new(left_child.stdout.take().unwrap());
        let mut right_out = right_child.stdin.take().unwrap();
        for line in left_in.lines() {
            writeln!(&mut right_out, "{}", line.unwrap()).unwrap();
        }
    }
    let left_ecode = left_child.wait().expect("failed to wait on child");
    let right_ecode = right_child.wait().expect("failed to wait on child");

    assert!(left_ecode.success());
    assert!(right_ecode.success());
}

三明治管生锈了怎么办？

how to do a sandwich pipe in rust?

rust

subprocess

pipe

stdio

spawn