Struct shutdown_async::ShutdownMonitor

pub struct ShutdownMonitor { /* private fields */ }

A ShutdownMonitor listens for the shutdown signal from a ShutdownController and tracks that the signal has been received.

Callers may query for whether the shutdown signal has been received or not.

Implementations

impl ShutdownMonitor

pub fn is_shutdown(&self) -> bool

Returns true if the shutdown signal has been received, and false otherwise.

Examples

#[tokio::main]
async fn main() {
  let shutdown = shutdown_async::ShutdownController::new();
  let mut monitor = shutdown.subscribe();
  assert!(!monitor.is_shutdown());
}

pub async fn recv(&mut self)

Receive the shutdown notice, waiting if necessary.

Examples

async fn long_lived_task(mut monitor: shutdown_async::ShutdownMonitor) {
   while !monitor.is_shutdown() {
      tokio::select! {
        _ = monitor.recv() => { return; }
        _ = async { /* do work */ } => { }
      }
  }
}

Trait Implementations

impl Debug for ShutdownMonitor

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

Formats the value using the given formatter.