Struct StreamingRunner 

pub struct StreamingRunner { /* private fields */ }

A streaming process runner that allows async iteration over output

Implementations

impl StreamingRunner

pub fn new(command: impl Into<String>) -> Self

Create a new streaming runner

pub fn cwd(self, path: impl Into<PathBuf>) -> Self

Set the working directory

pub fn env(self, env: HashMap<String, String>) -> Self

Set environment variables

pub fn stdin(self, content: impl Into<String>) -> Self

Set stdin content

pub fn stream(self) -> OutputStream

Start the process and return a stream of output chunks

pub async fn collect(self) -> Result<CommandResult>

Run to completion and collect all output