Struct CancellableProcessExecutor 

pub struct CancellableProcessExecutor { /* private fields */ }

Implementations

impl CancellableProcessExecutor

pub fn new(cancelled: Arc<Atomic<bool>>) -> CancellableProcessExecutor

pub fn is_cancelled(&self) -> bool

pub fn with_timeout(timeout: Duration) -> CancellableProcessExecutor

pub fn with_deadline(self, timeout: Duration) -> CancellableProcessExecutor

Bounds an existing flag-based executor with a deadline, so a wedged child becomes a reported failure instead of running forever.

Trait Implementations

impl Clone for CancellableProcessExecutor

fn clone(&self) -> CancellableProcessExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandExecutor for CancellableProcessExecutor

fn cancellation_requested(&self) -> bool

Whether the operation supervising this executor has requested cancellation. Test executors and ordinary process execution are not cancellable unless they opt in.

fn execute(&self, command: &CommandSpec) -> Result<CommandOutput, Error>

fn execute_with_stdin( &self, command: &CommandSpec, input: &mut (dyn Read + Send), ) -> Result<CommandOutput, Error>

fn stage_started(&self, _stage: ProvisionStage)

Report entry into a lifecycle stage. Callers that cover more than one command should hold a ProvisionStageGuard for the whole operation so concurrent stages remain visible between subprocesses.

fn stage_finished(&self, _stage: ProvisionStage)

Report exit from a lifecycle stage previously passed to Self::stage_started.

fn notify_notice(&self, _notice: &str)

Report a decision an operation made on the user’s behalf. This is not a failure: the work continues, and the user is told what changed.