lsp-cli 0.1.6

Command-line tool for talking to Language Server Protocol (LSP) servers from the terminal.
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

use super::*;

fn worker(messages: usize, bytes: usize, flagged_since: Option<Instant>) -> WriterWorker {
    let (sender, _) = mpsc::channel();
    let (acknowledge, _) = mpsc::channel();
    WriterWorker {
        sender: Some(sender),
        progress: Arc::new(Progress {
            messages: AtomicUsize::new(messages),
            bytes: AtomicUsize::new(bytes),
        }),
        flagged_since,
        next_id: 0,
        socket: None,
        cancelled: Arc::new(AtomicBool::new(false)),
        acknowledge,
        thread: None,
    }
}

#[test]
fn queue_flag_tracks_both_limits_and_clears_below_them() {
    let now = Instant::now();
    let mut writer = worker(MESSAGE_LIMIT, 1, None);
    assert_eq!(writer.outstanding(), (MESSAGE_LIMIT, 1));
    writer.refresh_flag(now);
    assert_eq!(
        writer.deadline(Duration::from_secs(2)),
        Some(now + Duration::from_secs(2))
    );

    writer
        .progress
        .messages
        .store(MESSAGE_LIMIT - 1, Ordering::Release);
    writer.progress.bytes.store(BYTE_LIMIT, Ordering::Release);
    writer.refresh_flag(now);
    assert!(writer.deadline(Duration::ZERO).is_some());

    writer
        .progress
        .bytes
        .store(BYTE_LIMIT - 1, Ordering::Release);
    writer.refresh_flag(now);
    assert_eq!(writer.deadline(Duration::ZERO), None);
}

#[test]
fn persistent_flag_times_out_at_configured_duration() {
    let started = Instant::now();
    let mut writer = worker(MESSAGE_LIMIT, 0, Some(started));
    assert!(!writer.timed_out(
        started + Duration::from_millis(1999),
        Duration::from_secs(2)
    ));
    assert!(writer.timed_out(started + Duration::from_secs(2), Duration::from_secs(2)));
}