atomr-core 0.3.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

//! ActorPath / Address spec parity.
//! `ActorPathSpec`, `AddressSpec`, `RelativeActorPathSpec`,
//! `RemotePathParsingSpec`.

use atomr_core::actor::{ActorPath, Address};

#[test]
fn local_address_round_trips() {
    let a = Address::local("MySys");
    assert!(a.has_local_scope());
    assert!(!a.has_global_scope());
    assert_eq!(a.system, "MySys");
    assert_eq!(a.host, None);
    assert_eq!(a.port, None);
}

#[test]
fn remote_address_carries_host_and_port() {
    let a = Address::remote("akka.tcp", "Sys", "10.0.0.1", 2552);
    assert!(!a.has_local_scope());
    assert!(a.has_global_scope());
    assert_eq!(a.host.as_deref(), Some("10.0.0.1"));
    assert_eq!(a.port, Some(2552));
}

#[test]
fn parse_local_address() {
    let a = Address::parse("akka://MySys").unwrap();
    assert_eq!(a.system, "MySys");
    assert_eq!(a.host, None);
}

#[test]
fn parse_remote_address() {
    let a = Address::parse("akka.tcp://MySys@10.0.0.1:2552").unwrap();
    assert_eq!(a.system, "MySys");
    assert_eq!(a.host.as_deref(), Some("10.0.0.1"));
    assert_eq!(a.port, Some(2552));
    assert_eq!(a.protocol, "akka.tcp");
}

#[test]
fn parse_invalid_address_yields_none() {
    assert!(Address::parse("not a url").is_none());
    assert!(Address::parse("").is_none());
}

#[test]
fn root_path_displays_with_address_prefix() {
    let p = ActorPath::root(Address::local("S"));
    assert_eq!(p.to_string(), "akka://S/");
    assert_eq!(p.depth(), 0);
}

#[test]
fn child_paths_compose() {
    let p = ActorPath::root(Address::local("S")).child("user").child("foo").child("bar");
    assert_eq!(p.name(), "bar");
    assert_eq!(p.depth(), 3);
    assert_eq!(p.to_string(), "akka://S/user/foo/bar");
}

#[test]
fn parent_strips_one_element() {
    let p = ActorPath::root(Address::local("S")).child("a").child("b").child("c");
    let parent = p.parent().unwrap();
    assert_eq!(parent.name(), "b");
    assert_eq!(parent.depth(), 2);
}

#[test]
fn parent_at_root_yields_none() {
    let p = ActorPath::root(Address::local("S"));
    assert!(p.parent().is_none());
}

#[test]
fn to_string_without_address_omits_prefix() {
    let p = ActorPath::root(Address::local("S")).child("user").child("foo");
    assert_eq!(p.to_string_without_address(), "/user/foo");
}

#[test]
fn paths_with_remote_address_display_remote_url() {
    let p = ActorPath::root(Address::remote("akka.tcp", "Sys", "host", 1)).child("user").child("a");
    assert_eq!(p.to_string(), "akka.tcp://Sys@host:1/user/a");
}

#[test]
fn equal_paths_are_equal() {
    let p1 = ActorPath::root(Address::local("S")).child("user").child("a");
    let p2 = ActorPath::root(Address::local("S")).child("user").child("a");
    assert_eq!(p1, p2);
}

#[test]
fn different_paths_are_unequal() {
    let p1 = ActorPath::root(Address::local("S")).child("user").child("a");
    let p2 = ActorPath::root(Address::local("S")).child("user").child("b");
    assert_ne!(p1, p2);
}