via 1.0.1

An async multi-threaded web framework for people who appreciate simplicity.
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
27
28
29
30

use tokio::signal;
use tokio::sync::watch;
use tokio::task::{self, JoinHandle};

use crate::Error;

pub fn wait_for_shutdown() -> (JoinHandle<Result<(), Error>>, watch::Receiver<bool>) {
    // Create a watch channel to notify the connections to initiate a
    // graceful shutdown process when the `ctrl_c` future resolves.
    let (tx, rx) = watch::channel(false);

    // Spawn a task to wait for a "Ctrl-C" signal to be sent to the process.
    let task = task::spawn(async move {
        match signal::ctrl_c().await {
            Ok(_) => tx.send(true).map_err(|_| {
                let message = "unable to notify connections to shutdown.";
                Error::new(message.to_string())
            }),
            Err(error) => {
                if cfg!(debug_assertions) {
                    eprintln!("unable to register the 'Ctrl-C' signal.");
                }

                Err(error.into())
            }
        }
    });

    (task, rx)
}