kx-utils 0.1.3

Common utils incubator
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

//
/// spawns a new actor and sets up bi-directional links
#[macro_export]
macro_rules! spawn {
    ($parent:expr, $actor:expr) => {{
        tracing::debug!("spawning : {}", $crate::stringify_expr!($actor));
        let new_actor_ref = kameo::spawn($actor);
        new_actor_ref.link(&$parent).await;
        $parent.link(&new_actor_ref).await;
        tracing::debug!("spawned  : {}", $crate::stringify_expr!($actor));
        new_actor_ref
    }};
}

#[macro_export]
macro_rules! stringify_expr {
    ($expr:expr) => {
        stringify!($expr).lines().collect::<Vec<_>>().join(" ")
    };
}

#[test]
fn remove_line_breaks() {
    let out = stringify_expr!([
        "line 1", "line 2", "line 3", "line 1", "line 2", "line 3", "line 1", "line 2", "line 3",
        "line 1", "line 2", "line 3",
    ]);
    let expected = r#"["line 1", "line 2", "line 3", "line 1", "line 2", "line 3", "line 1", "line 2", "line 3", "line 1", "line 2", "line 3",]"#;

    assert_eq!(out, expected);
}

#[macro_export]
macro_rules! spawn_in_thread {
    ($parent:expr, $actor:expr) => {{
        tracing::debug!("spawning in thread : {}", $crate::stringify_expr!($actor));
        let new_actor_ref = kameo::actor::spawn_in_thread($actor);
        new_actor_ref.link(&$parent).await;
        $parent.link(&new_actor_ref).await;
        tracing::debug!("spawned  in thread : {}", $crate::stringify_expr!($actor));
        new_actor_ref
    }};
}