How to asynchronously run a command and pipe the output

sleep_async.rs

use tokio::process::Command;
use tokio::io::{self, AsyncBufReadExt};

#[tokio::main]
async fn main() -> io::Result<()> {
    let shell_command = "sleep 2 && echo \"how\" && sleep 10 && echo \"yes\"";

    let mut child = Command::new("sh")
        .arg("-c")
        .arg(shell_command)
        .stdout(std::process::Stdio::piped())
        .spawn()
        .expect("Failed to spawn child process");

    let stdout = child.stdout.take().expect("Failed to open stdout");

    let reader = io::BufReader::new(stdout);
    let mut lines = reader.lines();

    // Asynchronously read lines from the stdout
    while let Some(line) = lines.next_line().await? {
        println!("{}", line);
    }

    // Await the child process to finish
    let status = child.await.expect("Child process encountered an error");

    println!("Process exited with status: {}", status);

    Ok(())
}