Struct CancellationToken

pub struct CancellationToken { /* private fields */ }

Cancellation token for request cancellation

Implementations

impl CancellationToken

pub fn new(request_id: Value) -> Self

Create a new cancellation token

pub fn is_cancelled(&self) -> bool

Check if cancellation was requested

pub fn cancel(&self)

Cancel this token

pub async fn cancelled(&self)

Wait for cancellation

pub fn request_id(&self) -> &Value

Get the request ID

pub async fn with_timeout<F, T>( &self, timeout: Duration, operation: F, ) -> Result<T, CancellationError>

where F: Future<Output = T>,

Run an operation with timeout and cancellation

Trait Implementations

impl Clone for CancellationToken

fn clone(&self) -> CancellationToken

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CancellationToken

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

Formats the value using the given formatter.