cairo-language-server 2.17.0-rc.2

The Cairo Language Server
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

use std::thread;

use super::*;

#[test]
fn test_sync() {
    let (sender, receiver) = trigger();

    sender.activate(42);
    assert_eq!(receiver.wait(), Some(42));

    sender.activate(43);
    assert_eq!(receiver.wait(), Some(43));

    drop(sender);
    assert_eq!(receiver.wait(), None);
}

#[test]
fn test_preserve_value_after_disconnect() {
    let (sender, receiver) = trigger();
    sender.activate(43);
    drop(sender);

    assert_eq!(receiver.wait(), Some(43));
}

#[test]
fn test_threaded() {
    let (sender, receiver) = trigger();
    thread::scope(|s| {
        s.spawn(move || {
            for i in 0..10_000 {
                sender.activate(i);
            }
        });

        s.spawn(move || {
            let past_i = -1;
            while let Some(i) = receiver.wait() {
                assert!(i > past_i);
            }
        });
    });
}

#[test]
fn test_drop_receiver() {
    let (sender, receiver) = trigger();
    drop(receiver);
    // This line should just do nothing.
    sender.activate(42);
}