Struct TriggerCancellationTokenOnError 

pub struct TriggerCancellationTokenOnError { /* private fields */ }

Test error policy that triggers a custom cancellation token on any error

This policy demonstrates the ErrorResponse::Custom behavior by capturing an external cancellation token and triggering it when any error occurs. Used for testing custom error handling actions.

Example

let cancel_token = CancellationToken::new();
let policy = TriggerCancellationTokenOnError::new(cancel_token.clone());

// Policy will trigger the token on any error via ErrorResponse::Custom

Implementations

impl TriggerCancellationTokenOnError

pub fn new(cancel_token: CancellationToken) -> Arc<Self>

Create a new policy that triggers the given cancellation token on errors

Trait Implementations

impl Debug for TriggerCancellationTokenOnError

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

Formats the value using the given formatter.

impl OnErrorPolicy for TriggerCancellationTokenOnError

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?