Struct PersistentOutputObserver 

pub struct PersistentOutputObserver { /* private fields */ }

Byte observers for persistent process output.

Callbacks run on stdout/stderr reader threads with arbitrary chunk boundaries. Keep them fast and non-blocking; offload synchronous I/O or heavier processing to another worker to avoid stalling the reader thread and backing up the child process pipe.

Implementations

impl PersistentOutputObserver

pub fn new() -> Self

Create a persistent output observer without callbacks.

pub fn with_stdout_bytes( self, callback: impl Fn(&[u8]) + Send + Sync + 'static, ) -> Self

Observe each stdout byte chunk read from the persistent process.

The callback runs on the stdout reader thread and must be fast/non-blocking.

pub fn with_stderr_bytes( self, callback: impl Fn(&[u8]) + Send + Sync + 'static, ) -> Self

Observe each stderr byte chunk read from the persistent process.

The callback runs on the stderr reader thread and must be fast/non-blocking.

Trait Implementations

impl Clone for PersistentOutputObserver

fn clone(&self) -> PersistentOutputObserver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PersistentOutputObserver

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PersistentOutputObserver

fn default() -> PersistentOutputObserver

Returns the “default value” for a type.