add chapter 07

Author: smallnest

asyncwait/src/runtimes.rs

@@ -139,7 +139,7 @@ pub fn futures_select() {
 
 pub fn smol_zip() {
     smol::block_on(async {
-        use smol::future::{try_zip, zip, FutureExt};
+        use smol::future::{try_zip, zip};
 
         let future1 = async { 1 };
         let future2 = async { 2 };

process/src/lib.rs

@@ -56,3 +56,75 @@ pub fn easy_process_example() {
     }
 
 }
+
+pub fn pipe() {
+    // 创建两个子进程，一个作为生产者，一个作为消费者
+
+    // 生产者进程
+    let producer = Command::new("echo")
+        .arg("Hello, Rust!")
+        .stdout(Stdio::piped())
+        .spawn()
+        .expect("Failed to start producer command");
+
+    // 消费者进程
+    let consumer = Command::new("grep")
+        .arg("Rust")
+        .stdin(producer.stdout.unwrap())
+        .output()
+        .expect("Failed to start consumer command");
+
+    // 获取消费者的输出
+    let output = String::from_utf8_lossy(&consumer.stdout);
+    println!("Output: {:?}", output);
+}
+
+pub fn spawn_a_process() {
+    let output = Command::new("echo")
+        .arg("Hello world")
+        .output()
+        .expect("Failed to execute command");
+
+    assert_eq!(b"Hello world\n", output.stdout.as_slice());
+}
+
+pub fn process_io() {
+    let echo_child = Command::new("echo")
+        .arg("Oh no, a tpyo!")
+        .stdout(Stdio::piped())
+        .spawn()
+        .expect("Failed to start echo process");
+
+    let echo_out = echo_child.stdout.expect("Failed to open echo stdout");
+
+    let sed_child = Command::new("sed")
+        .arg("s/tpyo/typo/")
+        .stdin(Stdio::from(echo_out))
+        .stdout(Stdio::piped())
+        .spawn()
+        .expect("Failed to start sed process");
+
+    let output = sed_child.wait_with_output().expect("Failed to wait on sed");
+    assert_eq!(b"Oh no, a typo!\n", output.stdout.as_slice());
+}
+
+pub fn child() {
+    let mut child = Command::new("/bin/cat")
+        .arg("Cargo.toml")
+        .spawn()
+        .expect("failed to execute child");
+
+    let ecode = child.wait().expect("failed to wait on child");
+
+    assert!(ecode.success());
+}
+
+pub fn kill() {
+    let mut command = Command::new("yes");
+    if let Ok(mut child) = command.spawn() {
+        println!("Child's ID is {}", child.id());
+        child.kill().expect("command wasn't running");
+    } else {
+        println!("yes command didn't start");
+    }
+}

process/src/main.rs

@@ -1,63 +1,14 @@
-use std::process::{Command, Stdio};
 use process::*;
 
 fn main() {
     spawn_a_process();
     process_io();
     child();
     kill();
+    pipe();
 
     async_process_example();
     process_control_example();
     easy_process_example();
 }
 
-fn spawn_a_process() {
-    let output = Command::new("echo")
-        .arg("Hello world")
-        .output()
-        .expect("Failed to execute command");
-
-    assert_eq!(b"Hello world\n", output.stdout.as_slice());
-}
-
-fn process_io() {
-    let echo_child = Command::new("echo")
-        .arg("Oh no, a tpyo!")
-        .stdout(Stdio::piped())
-        .spawn()
-        .expect("Failed to start echo process");
-
-    let echo_out = echo_child.stdout.expect("Failed to open echo stdout");
-
-    let sed_child = Command::new("sed")
-        .arg("s/tpyo/typo/")
-        .stdin(Stdio::from(echo_out))
-        .stdout(Stdio::piped())
-        .spawn()
-        .expect("Failed to start sed process");
-
-    let output = sed_child.wait_with_output().expect("Failed to wait on sed");
-    assert_eq!(b"Oh no, a typo!\n", output.stdout.as_slice());
-}
-
-fn child() {
-    let mut child = Command::new("/bin/cat")
-        .arg("Cargo.toml")
-        .spawn()
-        .expect("failed to execute child");
-
-    let ecode = child.wait().expect("failed to wait on child");
-
-    assert!(ecode.success());
-}
-
-fn kill() {
-    let mut command = Command::new("yes");
-    if let Ok(mut child) = command.spawn() {
-        println!("Child's ID is {}", child.id());
-        child.kill().expect("command wasn't running");
-    } else {
-        println!("yes command didn't start");
-    }
-}