move lsp-server to a separate repository

1 files changed, 0 insertions, 57 deletions

diff --git a/crates/gen_lsp_server/src/stdio.rs b/crates/gen_lsp_server/src/stdio.rs
deleted file mode 100644
index f8931f2dc..000000000
--- a/crates/gen_lsp_server/src/stdio.rs
+++ /dev/null
@@ -1,57 +0,0 @@
-use std::{
-    io::{stdin, stdout},
-    thread,
-};
-
-use crossbeam_channel::{bounded, Receiver, Sender};
-use lsp_types::notification::Exit;
-
-use crate::{RawMessage, Result};
-
-pub fn stdio_transport() -> (Receiver<RawMessage>, Sender<RawMessage>, Threads) {
-    let (writer_sender, writer_receiver) = bounded::<RawMessage>(16);
-    let writer = thread::spawn(move || {
-        let stdout = stdout();
-        let mut stdout = stdout.lock();
-        writer_receiver.into_iter().try_for_each(|it| it.write(&mut stdout))?;
-        Ok(())
-    });
-    let (reader_sender, reader_receiver) = bounded::<RawMessage>(16);
-    let reader = thread::spawn(move || {
-        let stdin = stdin();
-        let mut stdin = stdin.lock();
-        while let Some(msg) = RawMessage::read(&mut stdin)? {
-            let is_exit = match &msg {
-                RawMessage::Notification(n) => n.is::<Exit>(),
-                _ => false,
-            };
-
-            reader_sender.send(msg).unwrap();
-
-            if is_exit {
-                break;
-            }
-        }
-        Ok(())
-    });
-    let threads = Threads { reader, writer };
-    (reader_receiver, writer_sender, threads)
-}
-
-pub struct Threads {
-    reader: thread::JoinHandle<Result<()>>,
-    writer: thread::JoinHandle<Result<()>>,
-}
-
-impl Threads {
-    pub fn join(self) -> Result<()> {
-        match self.reader.join() {
-            Ok(r) => r?,
-            Err(_) => Err("reader panicked")?,
-        }
-        match self.writer.join() {
-            Ok(r) => r,
-            Err(_) => Err("writer panicked")?,
-        }
-    }
-}