meio 0.97.0

A compact actors framework for the async epoch in Rust & Tokio
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

//! Module contains stream to connect signals to actors.

use crate::handlers::Action;
use futures::{stream::BoxStream, FutureExt, StreamExt};
use tokio::signal;

/// `Ctrl-C` signal handler.
pub struct CtrlC;

impl Action for CtrlC {}

impl CtrlC {
    /// Creates an attachable stream of `Ctrl-C` for an `Actor`.
    pub fn stream() -> BoxStream<'static, CtrlC> {
        signal::ctrl_c()
            .into_stream()
            .map(|res| {
                if let Err(err) = res {
                    log::error!("Ctrl-C signal handler failed: {}", err);
                }
                CtrlC
            })
            .boxed()
    }
}