fix test

Author: naijauser

cli/tests/execute_block.rs

@@ -149,31 +149,28 @@ async fn execute_block_works() {
                 .unwrap()
         }
 
-        let mut block_execution = execute_block_range(&ws_url, from, to);
+        let block_execution = execute_block_range(&ws_url, from, to);
+
+        // Let the process run to completion and capture its full output. `Child::stderr` is an
+        // `Option` that can only be `take()`n once, and `wait_for_stream_pattern_match` stops
+        // reading as soon as it finds a match, so streaming it twice would either panic on the
+        // second `take()` or silently miss data buffered past the first match. Capturing the
+        // full output up front and matching against it lets us check both conditions safely.
+        let output = block_execution.wait_with_output().await.unwrap();
+        let stderr = String::from_utf8_lossy(&output.stderr);
 
         // Expect the last block in the range to be successfully executed.
         let expected_output = format!(r#".*Block #{} successfully executed"#, to);
         let re = Regex::new(expected_output.as_str()).unwrap();
-        let matched =
-            common::wait_for_stream_pattern_match(block_execution.stderr.take().unwrap(), re).await;
-
-        // Assert that all blocks in the range were executed.
-        assert!(matched.is_ok());
+        assert!(re.is_match(&stderr));
 
         // Assert that the block after is not executed.
         let expected_output = format!(r#".*Block #{} successfully executed"#, to + 1);
         let re = Regex::new(expected_output.as_str()).unwrap();
-        let matched =
-            common::wait_for_stream_pattern_match(block_execution.stderr.take().unwrap(), re).await;
-        assert!(matched.is_err());
+        assert!(!re.is_match(&stderr));
 
         // Assert that the block-execution exited successfully.
-        assert!(block_execution
-            .wait_with_output()
-            .await
-            .unwrap()
-            .status
-            .success());
+        assert!(output.status.success());
     })
     .await
 }