noticeable 0.2.0

A library for lazy observables
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

use crate::observable::Observable;
use std::sync::{Arc, Mutex};

#[test]
fn can_create() {
    let _: Observable<()> = Observable::new();
}

#[test]
fn can_subscribe() {
    let mut observable: Observable<()> = Observable::new();
    let _ = observable.subscribe(|()| ());
}

#[test]
fn is_notified() {
    //Arrange
    let mut was_notified = false;
    {
        let mut observable: Observable<()> = Observable::new();
        let _subscriber = observable.subscribe(|()| was_notified = true);
        //Act
        observable.notify(());
    }
    //Assert
    assert!(was_notified);
}

#[test]
fn is_not_notified_twice() {
    //Arrange
    let mut outer_notification = false;
    let mut inner_notification = false;
    {
        let mut observable: Observable<()> = Observable::new();
        {
            let _subscriber = observable.subscribe(|()| inner_notification = true);
        }
        let _subscriber = observable.subscribe(|()| outer_notification = true);
        //Act
        observable.notify(());
    }
    //Assert
    assert!(outer_notification);
    assert!(!inner_notification);
}

#[test]
fn can_send_between_threads() {
    let mut observable: Observable<()> = Observable::new();
    let some_data = Arc::new(Mutex::new(false));
    let _subscriber = observable.subscribe(|()| {
        let mut data = some_data.lock().unwrap();
        *data = true;
    });
    std::thread::scope(|s| {
        s.spawn(|| {
            observable.notify(());
        });
    });
    assert!(*some_data.lock().unwrap());
}