1 2 3 4 5 6 7 8 9 10 11 12
use futures::task::AtomicTask; #[derive(Debug)] pub(crate) struct ShutdownTask { pub task: AtomicTask, } impl ShutdownTask { pub fn notify(&self) { self.task.notify(); } }