lunatic 0.14.1

Helper library for building Rust applications that run on lunatic.
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

use std::time::Duration;

use lunatic::{sleep, spawn_link, ProcessConfig};
use lunatic_test::test;

#[test]
fn simple_task() {
    let task = spawn_link!(@task |a = 2, b = {3}| a + b);
    assert_eq!(task.result(), 5);
}

#[allow(unreachable_code)]
#[test]
#[should_panic]
fn failing_child_kills_task() {
    let task = spawn_link!(@task || panic!(""));
    task.result()
}

#[test]
#[should_panic]
fn result_must_be_called() {
    let _ = spawn_link!(@task  || {});
}

#[test]
fn recursive_count() {
    let mut config = ProcessConfig::new().unwrap();
    config.set_can_spawn_processes(true);
    let task = spawn_link!(@task &config, |n = 1_000| recursive_count_sub(n));
    assert_eq!(500500, task.result());
}

fn recursive_count_sub(n: i32) -> i32 {
    if n > 0 {
        n + spawn_link!(@task |n = {n - 1}| recursive_count_sub(n)).result()
    } else {
        0
    }
}

#[test]
fn timeout_task() {
    let task = spawn_link!(@task || sleep(Duration::from_millis(25)));
    let result = task.result_timeout(Duration::from_millis(10));
    assert!(result.unwrap_err().is_timed_out());
}