Struct ProcessHandle 

pub struct ProcessHandle { /* private fields */ }

Handle to an in-flight streaming run. Caller stores it (e.g. in a runId-keyed map) so a later cancel() can find it.

Dropping the handle does NOT cancel the run — the reader threads + wait thread continue independently. Use cancel() explicitly when the user closes the connection.

Implementations

impl ProcessHandle

pub fn cancel(&self) -> Result<(), StreamError>

SIGTERM the process, then SIGKILL after 1.5s if it’s still alive. The CLI is supposed to flush a final result on SIGTERM but we don’t trust it to do so forever.

pub fn was_cancelled(&self) -> bool

Whether cancel() was called. Tagged on the final Exited event.

Trait Implementations

impl Clone for ProcessHandle

fn clone(&self) -> ProcessHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessHandle

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

Formats the value using the given formatter.