Struct RunningProcess 

pub struct RunningProcess {
    pub process: Process,
    /* private fields */
}

A process that is currently running and being monitored.

Fork Safety

This handle contains both a PID and owned file descriptors for process I/O. Upon fork, the descriptors are inherited. Standard O_CLOEXEC behavior applies after exec.

Fields

process: Process

Handle to the process.

Implementations

impl RunningProcess

pub fn register_with_reactor( &mut self, reactor: &mut Reactor, ) -> Result<(), CoreError>

Register active stdio pipe descriptors with a reactor.

Call this once after spawn_start when the process was started with captured output or stdin data. The assigned tokens are kept internally and later matched by Self::handle_reactor_event.

pub fn handle_reactor_event( &mut self, reactor: &mut Reactor, event: &Event, ) -> Result<(), CoreError>

Apply one reactor readiness event to this process’ stdio drain state.

Events for unrelated tokens are ignored. Callers remain responsible for waiting on Self::process and driving the reactor until Self::io_done returns true.

pub fn io_done(&self) -> bool

Return whether all managed stdio pipes have been drained or closed.

pub fn stdout_paused(&self) -> bool

Return whether the stdout stream is paused on a full sink queue.

pub fn stderr_paused(&self) -> bool

Return whether the stderr stream is paused on a full sink queue.

pub fn resume_stdout( &mut self, reactor: &mut Reactor, ) -> Result<bool, CoreError>

Re-deliver the held stdout chunk (if any) and re-register the fd when the sink has room again. Returns true when the stream is resumed.

pub fn resume_stderr( &mut self, reactor: &mut Reactor, ) -> Result<bool, CoreError>

Re-deliver the held stderr chunk (if any) and re-register the fd when the sink has room again. Returns true when the stream is resumed.

pub fn into_output_parts(self) -> (Vec<u8>, Vec<u8>)

Consume the running process handle and return captured stdout/stderr buffers.