actix-daemon-utils

Daemon Utilities by actix.

Documentation

Features

• Graceful Stop by singals(hangup, interrupt, quit or terminate)
• Loop daemon(looper or delayer)

TODO

• run in #[actix::main]

Examples

```rust use actixdaemonutils::{ actix::{ prelude::*, System, }, graceful_stop::{GracefulStop}, looper::{Looper, Task}, }; use std::{ sync::mpsc, thread, time::Duration, };

struct MyActor { msg: String, seconds: u64 }

impl Actor for MyActor { type Context = Context; }

impl Handler for MyActor { type Result = Option;

fn handle(&mut self, _msg: Task, _ctx: &mut Self::Context) -> Self::Result {
    println!("{}", self.msg);
    Some(Duration::from_secs(self.seconds))
}

}

// Note. #[actix::main] don't work. I don't know how to deal with. fn main() { let (tx, rx) = mpsc::channel::<()>();

let sys = System::new();
let graceful_stop = GracefulStop::new_with_sender(tx);
sys.block_on( async { 
    let actor1 = MyActor { msg: "x".to_string(), seconds: 1 }.start();
    let actor2 = MyActor { msg: "y".to_string(), seconds: 3 }.start();
    let looper1 = Looper::new(actor1.recipient(), graceful_stop.clone_system_terminator()).start();
    let looper2 = Looper::new(actor2.recipient(), graceful_stop.clone_system_terminator()).start();
    graceful_stop
        .subscribe(looper1.recipient())
        .subscribe(looper2.recipient())
        .start();
    });

let sys2 = System::current();
thread::spawn(move || {
    rx.recv().unwrap();

    println!("ended");

    sys2.stop();
});

let _ = sys.run();

println!("main terminated");

} ```