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

use std::io::{BufReader, Read};
use std::sync::mpsc::{self, Receiver, Sender};
use std::thread;

use super::IncomingMessage;
use crate::lsp::transport::{log_debug_message, read_message};

pub(super) fn spawn_reader<R>(reader: R, debug: bool) -> Receiver<IncomingMessage>
where
    R: Read + Send + 'static,
{
    let (sender, receiver) = mpsc::channel();
    thread::spawn(move || reader_loop(reader, &sender, debug));
    receiver
}

fn reader_loop<R>(reader: R, sender: &Sender<IncomingMessage>, debug: bool)
where
    R: Read,
{
    let mut reader = BufReader::new(reader);

    loop {
        match read_message(&mut reader) {
            Ok(Some(message)) => {
                log_debug_message(debug, "<- ", &message);
                if sender.send(IncomingMessage::Message(message)).is_err() {
                    return;
                }
            }
            Ok(None) => {
                let _ = sender.send(IncomingMessage::EndOfStream);
                return;
            }
            Err(error) => {
                let _ = sender.send(IncomingMessage::Error(error));
                return;
            }
        }
    }
}