spark-channel 0.0.1

A generic channel listener for Spark
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! # Spark Channel Cancellation Token
//!
//! This module contains a cancellation token that wraps the [`CancellationToken`] type from the [`tokio-util`] crate. This is used to cancel the execution of a running task.

use tokio_util::sync::CancellationToken;

use crate::listener::SparkChannelCancellationTrait;

/// A cancellation token for the Spark Channel.
#[derive(Clone)]
pub struct SparkChannelCancellationToken(pub CancellationToken);

impl SparkChannelCancellationToken {
    /// Creates a new cancellation token.
    #[must_use]
    #[inline]
    pub fn new() -> Self {
        Self(CancellationToken::new())
    }
}

impl SparkChannelCancellationTrait for SparkChannelCancellationToken {
    fn cancel_execution(&self) {
        self.0.cancel();
    }
}