1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
pub type PipelineCancellationToken = tokio_util::sync::CancellationToken; pub fn create_pipeline_cancellation_token() -> PipelineCancellationToken { tokio_util::sync::CancellationToken::new() } #[cfg(test)] mod tests { use super::*; #[test] fn create_cancellation_token() { create_pipeline_cancellation_token(); } }