Function p3_cli_stdout_flush

tests/all/cli_tests.rs:2962–3006

()

    #[test]
    #[cfg_attr(not(feature = "component-model-async"), ignore)]
    fn p3_cli_stdout_flush() -> Result<()> {
        let mut child = get_wasmtime_command()?
            .arg("-Sp3")
            .arg("-Wcomponent-model-async")
            .arg(P3_CLI_STDOUT_FLUSH_COMPONENT)
            .stdin(Stdio::piped())
            .stdout(Stdio::piped())
            .stderr(Stdio::piped())
            .spawn()?;

        let mut stdin = child.stdin.take().unwrap();
        let mut stdout = child.stdout.take().unwrap();

        let (tx, rx) = std::sync::mpsc::channel();
        let reader = thread::spawn(move || {
            let mut buf = [0u8; 5];
            let res = stdout.read_exact(&mut buf).map(|()| buf);
            let _ = tx.send(res);
        });

        let buf = match rx.recv_timeout(std::time::Duration::from_secs(100)) {
            Ok(Ok(buf)) => buf,
            Ok(Err(e)) => {
                let _ = child.kill();
                let _ = child.wait();
                return Err(e.into());
            }
            Err(_) => {
                let _ = child.kill();
                let _ = child.wait();
                let _ = reader.join();
                panic!("guest stdout was not flushed");
            }
        };
        assert_eq!(&buf, b"READY");

        stdin.write_all(b"x")?;
        drop(stdin);

        let output = child.wait_with_output()?;
        reader.join().unwrap();
        assert!(output.status.success());

        Ok(())
    }

    #[tokio::test]
    async fn p3_cli_serve_post_return() -> Result<()> {