nimiq-utils 0.2.0

Various utilities (e.g., CRC, Merkle proofs, timers) for Nimiq's Rust implementation
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
102
103
104
105
106
107
108
109
110
111

use nimiq_utils::observer::*;
use std::sync::Arc;
use std::sync::RwLock;

#[test]
fn it_can_register_notify_deregister() {
    let mut notifier: Notifier<u32> = Notifier::new();

    let event1_rc1 = Arc::new(RwLock::new(0));
    let event1_rc2 = event1_rc1.clone();
    let handle1 = notifier.register(move |e: &u32| *event1_rc2.write().unwrap() = e.clone());
    assert_eq!(*event1_rc1.read().unwrap(), 0);

    let event2_rc1 = Arc::new(RwLock::new(0));
    let event2_rc2 = event2_rc1.clone();
    let handle2 = notifier.register(move |e: &u32| *event2_rc2.write().unwrap() = e.clone());
    assert_eq!(*event2_rc1.read().unwrap(), 0);

    notifier.notify(42);
    assert_eq!(*event1_rc1.read().unwrap(), 42);
    assert_eq!(*event2_rc1.read().unwrap(), 42);

    notifier.notify(69);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 69);

    notifier.deregister(handle1);

    notifier.notify(4711);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);

    notifier.deregister(handle2);

    notifier.notify(815);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);

    // noop
    notifier.deregister(handle2);

    let event3_rc1 = Arc::new(RwLock::new(0));
    let event3_rc2 = event3_rc1.clone();
    let handle3 = notifier.register(move |e: &u32| *event3_rc2.write().unwrap() = e.clone());
    assert_eq!(*event3_rc1.read().unwrap(), 0);

    let event4_rc1 = Arc::new(RwLock::new(0));
    let event4_rc2 = event4_rc1.clone();
    let _handle4 = notifier.register(move |e: &u32| *event4_rc2.write().unwrap() = e.clone());
    assert_eq!(*event4_rc1.read().unwrap(), 0);

    notifier.notify(5555);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);
    assert_eq!(*event3_rc1.read().unwrap(), 5555);
    assert_eq!(*event4_rc1.read().unwrap(), 5555);

    notifier.deregister(handle3);

    notifier.notify(11);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);
    assert_eq!(*event3_rc1.read().unwrap(), 5555);
    assert_eq!(*event4_rc1.read().unwrap(), 11);

    let event5_rc1 = Arc::new(RwLock::new(0));
    let event5_rc2 = event5_rc1.clone();
    let handle5 = notifier.register(move |e: &u32| *event5_rc2.write().unwrap() = e.clone());
    assert_eq!(*event5_rc1.read().unwrap(), 0);

    notifier.notify(999);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);
    assert_eq!(*event3_rc1.read().unwrap(), 5555);
    assert_eq!(*event4_rc1.read().unwrap(), 999);
    assert_eq!(*event5_rc1.read().unwrap(), 999);

    notifier.deregister(handle5);

    notifier.notify(6666);
    assert_eq!(*event1_rc1.read().unwrap(), 69);
    assert_eq!(*event2_rc1.read().unwrap(), 4711);
    assert_eq!(*event3_rc1.read().unwrap(), 5555);
    assert_eq!(*event4_rc1.read().unwrap(), 6666);
    assert_eq!(*event5_rc1.read().unwrap(), 999);
}

#[test]
fn it_can_pass_through_notifications() {
    let mut notifier: PassThroughNotifier<u32> = PassThroughNotifier::new();

    let event1_rc1 = Arc::new(RwLock::new(0));
    let event1_rc2 = event1_rc1.clone();
    notifier.register(move |e: u32| *event1_rc2.write().unwrap() = e);
    assert_eq!(*event1_rc1.read().unwrap(), 0);

    let event2_rc1 = Arc::new(RwLock::new(0));
    let event2_rc2 = event2_rc1.clone();
    let _handle2 = notifier.register(move |e: u32| *event2_rc2.write().unwrap() = e);
    assert_eq!(*event2_rc1.read().unwrap(), 0);

    notifier.notify(42);
    assert_eq!(*event1_rc1.read().unwrap(), 0);
    assert_eq!(*event2_rc1.read().unwrap(), 42);

    notifier.deregister();

    notifier.notify(4711);
    assert_eq!(*event1_rc1.read().unwrap(), 0);
    assert_eq!(*event2_rc1.read().unwrap(), 42);
}