hydra 0.1.40

A framework for writing fault tolerant, highly scalable applications with the Rust programming language.
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use std::time::Duration;

use hydra::Message;
use hydra::Process;
use hydra::ProcessFlags;
use hydra::SystemMessage;

#[hydra::test]
async fn link_works() {
    let pid = Process::spawn(async {
        Process::spawn_link(async {
            panic!("we died!");
        });
        let _ = Process::receive::<()>().await;
    });

    Process::sleep(Duration::from_millis(10)).await;

    assert!(!Process::alive(pid));
}

#[hydra::test]
async fn link_trap_exit_works() {
    Process::set_flags(ProcessFlags::TRAP_EXIT);

    let pid = Process::spawn_link(async {
        panic!("we died!");
    });

    let message: Message<()> = Process::receive().await;

    if let Message::System(SystemMessage::Exit(from, exit_reason)) = message {
        assert!(from == pid);
        assert!(exit_reason == "we died!");
    } else {
        panic!("Expected exit signal!");
    }
}

#[hydra::test]
async fn unlink_works() {
    let pid = Process::spawn_link(async {
        Process::sleep(Duration::from_millis(10)).await;
        panic!("we died!");
    });

    Process::unlink(pid);
}