Struct RunControl 

pub struct RunControl { /* private fields */ }

Out-of-band pause/resume/cancel control for a run, shared (Arc) between FlowApp (which the host’s pause/resume/stop commands signal) and the Executor (which polls it at node boundaries). One instance is created per run and registered under that run’s execution id, so several flows (e.g. multiple canvas tabs) can run and be steered independently.

Implementations

impl RunControl

pub fn phase(&self) -> RunPhase

pub fn reset(&self)

Reset to Running at the start of a run so a stale cancel/pause from a prior run can’t leak into the next one.

pub fn pause(&self)

Request a pause. No-op if already cancelling.

pub fn resume(&self)

Release a pause. No-op if cancelling.

pub fn cancel(&self)

Request cancellation; takes precedence over pause and wakes any waiter.

pub fn is_cancelling(&self) -> bool

pub fn resolve_review(&self, approved: bool)

Record a human verdict for the AI review gate and release the pause. The executor picks the decision up via RunControl::take_review.

pub fn take_review(&self) -> Option<ReviewDecision>

Take the pending review decision, if any, clearing the slot.

pub async fn wait_while_paused(&self)

Block while the phase is Paused, returning once resumed or cancelling.

Trait Implementations

impl Default for RunControl

fn default() -> Self

Returns the “default value” for a type.