Struct Subagent 

pub struct Subagent {
    pub node: NodeId,
    /* private fields */
}

A handle to a running subagent process and the down side of its control channel. Upward messages arrive on the reactor’s merged channel, not here.

Fields

node: NodeId

Implementations

impl Subagent

pub fn pid(&self) -> i32

pub fn join_reader(&mut self)

Wait for the stdout reader to finish (bounded: the pipe has EOF’d once the child is reapable). After this, every frame the child ever wrote has been forwarded.

pub fn pgid(&self) -> i32

pub fn send(&mut self, msg: &ControlMsg) -> Result<()>

Send a control message down (Ping / Cancel / Inject).

pub fn mark_reaped(&mut self)

Mark that the reactor already reaped this child (via waitpid(-1)), so teardown won’t signal a possibly-reused pid.

pub fn kill(&mut self)

Immediate, unconditional teardown of the whole process group. The graceful ladder (cancel → SIGTERM → SIGKILL over time) is driven by the reactor via kill.rs; this is the backstop.

Trait Implementations

impl Drop for Subagent

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.