observable-tree 0.1.0

Reactive Observable BTree
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

use std::sync::Arc;
use tokio::sync::Mutex;

use observable_tree::BTree;

#[tokio::main]
async fn main() {
    let tree = BTree::start(1000);
    let btree = Arc::new(Mutex::new(tree));

    let btree_main = btree.clone();
    let m = btree_main.lock().await;
    let ins = (*m).insert("hello".to_string(), 5).await;
    assert!(ins.unwrap().is_none());

    let cont = (*m).contains("hello".to_string()).await;
    assert!(cont.unwrap());

    {
        let btree_async = btree.clone();
        tokio::spawn(async move {
            let t_m = btree_async.lock().await;
            let ins = (*t_m).insert("wow".to_string(), 76).await;
            assert!(ins.unwrap().is_none());

            let cont = (*t_m).contains("wow".to_string()).await;
            assert!(cont.unwrap());
        });
        println!("Done async 1");
    };

    {
        let btree_async2 = btree.clone();
        tokio::spawn(async move {
            let t_m = btree_async2.lock().await;

            let cont = (*t_m).contains("wow".to_string()).await;
            assert!(cont.unwrap());
            let cont = (*t_m).contains("hello".to_string()).await;
            assert!(cont.unwrap());
        });
        println!("Done async 2")
    };

    print!("Done!")
}