Struct InterruptionDetector 

pub struct InterruptionDetector { /* private fields */ }

Tracks active turns and manages cancellation tokens.

Implementations

impl InterruptionDetector

pub fn new() -> Self

pub async fn start_turn(&self, key: TurnKey) -> CancelToken

Register a new turn for the given key.

If there is already an active turn for this key, it is cancelled first. Returns the cancellation token for the new turn — the handler should check token.is_cancelled() periodically.

pub async fn finish_turn(&self, key: &TurnKey)

Finish a turn (normal completion). Removes the token from tracking.

pub async fn has_active_turn(&self, key: &TurnKey) -> bool

Check if a turn is currently active for the given key.

pub async fn active_count(&self) -> usize

Get the number of active turns.

pub async fn cancel_all(&self)

Cancel all active turns (e.g. on shutdown).

Trait Implementations

impl Default for InterruptionDetector

fn default() -> Self

Returns the “default value” for a type.