Struct CancelOnError 

pub struct CancelOnError { /* private fields */ }

Error policy that triggers cancellation based on error patterns

This policy analyzes error messages and returns ErrorResponse::Shutdown when:

• No patterns are specified (cancels on any error)
• Error message matches one of the specified patterns

The TaskTracker handles the actual cancellation - this policy just makes the decision.

Example

// Cancel on any error
let policy = CancelOnError::new();

// Cancel only on specific error patterns
let (policy, _token) = CancelOnError::with_patterns(
    vec!["OutOfMemory".to_string(), "DeviceError".to_string()]
);

Implementations

impl CancelOnError

pub fn new() -> Arc<Self>

Create a new cancel-on-error policy that cancels on any error

Returns a policy with no error patterns, meaning it will cancel the TaskTracker on any task failure.

pub fn with_patterns( error_patterns: Vec<String>, ) -> (Arc<Self>, CancellationToken)

Create a new cancel-on-error policy with custom error patterns, returning Arc and token

Arguments

• error_patterns - List of error message patterns that trigger cancellation

Trait Implementations

impl ArcPolicy for CancelOnError

fn new_arc(self) -> Arc<Self>

Create an Arc-wrapped instance of this policy

impl Debug for CancelOnError

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

Formats the value using the given formatter.

impl OnErrorPolicy for CancelOnError

fn create_child(&self) -> Arc<dyn OnErrorPolicy>

Create a child policy for a child tracker

fn create_context(&self) -> Option<Box<dyn Any + Send + 'static>>

Create per-task context state (None if policy is stateless)

fn on_error(&self, error: &Error, context: &mut OnErrorContext) -> ErrorResponse

Handle a task failure and return the desired response

fn allow_continuation(&self, _error: &Error, _context: &OnErrorContext) -> bool

Should continuations be allowed for this error?

fn should_reschedule(&self, _error: &Error, _context: &OnErrorContext) -> bool

Should this continuation be rescheduled through the scheduler?