Struct OutputStream 

pub struct OutputStream { /* private fields */ }

Stream of output chunks from a process

Implementations

impl OutputStream

pub async fn next(&mut self) -> Option<OutputChunk>

Receive the next chunk

pub fn kill(&mut self)

Stop the process using the configured kill signal (default SIGTERM).

This can be called from inside the consumption loop to stop a long-running or endless process; a terminating OutputChunk::Exit is still delivered afterwards.

pub fn kill_with(&mut self, signal: &str)

Stop the process using an explicit signal, overriding the configured kill signal for this call.

pub async fn collect(self) -> (Vec<u8>, Vec<u8>, i32)

Collect all remaining output into vectors

pub async fn collect_stdout(self) -> Vec<u8>

Collect stdout only, discarding stderr

Trait Implementations

impl AsyncIterator for OutputStream

type Item = OutputChunk

fn next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the next item from the iterator

impl Drop for OutputStream

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.