mirror of
https://github.com/denoland/deno.git
synced 2024-12-27 01:29:14 -05:00
21 lines
432 B
Rust
21 lines
432 B
Rust
|
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
|
||
|
|
|
||
|
|
use tokio_util::sync::CancellationToken;
|
||
|
|
|
||
|
|
#[derive(Debug, Default, Clone)]
|
||
|
|
pub struct AsyncFlag(CancellationToken);
|
||
|
|
|
||
|
|
impl AsyncFlag {
|
||
|
|
pub fn raise(&self) {
|
||
|
|
self.0.cancel();
|
||
|
|
}
|
||
|
|
|
||
|
|
pub fn is_raised(&self) -> bool {
|
||
|
|
self.0.is_cancelled()
|
||
|
|
}
|
||
|
|
|
||
|
|
pub fn wait_raised(&self) -> impl std::future::Future<Output = ()> + '_ {
|
||
|
|
self.0.cancelled()
|
||
|
|
}
|
||
|
|
}
|