wind_tunnel_runner 0.1.0-alpha.2

The Wind Tunnel runner
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use tokio::signal;
use wind_tunnel_core::prelude::ShutdownHandle;

pub(crate) fn start_shutdown_listener(
    runtime: &tokio::runtime::Runtime,
) -> anyhow::Result<ShutdownHandle> {
    let (tx, _) = tokio::sync::broadcast::channel(1);

    let sender = tx.clone();
    runtime.spawn(async move {
        signal::ctrl_c()
            .await
            .expect("Failed to receive Ctrl-C signal");
        sender
            .send(())
            .expect("Received shutdown signal but failed to notify listeners");
        println!("Received shutdown signal, shutting down...");
    });

    Ok(ShutdownHandle::new(tx))
}