1 files changed, 0 insertions, 46 deletions
diff --git a/vendor/lsp-server/src/socket.rs b/vendor/lsp-server/src/socket.rs
deleted file mode 100644
index 36d728456..000000000
--- a/vendor/lsp-server/src/socket.rs
+++ /dev/null
@@ -1,46 +0,0 @@
-use std::{
-    io::{self, BufReader},
-    net::TcpStream,
-    thread,
-};
-
-use crossbeam_channel::{bounded, Receiver, Sender};
-
-use crate::{
-    stdio::{make_io_threads, IoThreads},
-    Message,
-};
-
-pub(crate) fn socket_transport(
-    stream: TcpStream,
-) -> (Sender<Message>, Receiver<Message>, IoThreads) {
-    let (reader_receiver, reader) = make_reader(stream.try_clone().unwrap());
-    let (writer_sender, writer) = make_write(stream);
-    let io_threads = make_io_threads(reader, writer);
-    (writer_sender, reader_receiver, io_threads)
-}
-
-fn make_reader(stream: TcpStream) -> (Receiver<Message>, thread::JoinHandle<io::Result<()>>) {
-    let (reader_sender, reader_receiver) = bounded::<Message>(0);
-    let reader = thread::spawn(move || {
-        let mut buf_read = BufReader::new(stream);
-        while let Some(msg) = Message::read(&mut buf_read).unwrap() {
-            let is_exit = matches!(&msg, Message::Notification(n) if n.is_exit());
-            reader_sender.send(msg).unwrap();
-            if is_exit {
-                break;
-            }
-        }
-        Ok(())
-    });
-    (reader_receiver, reader)
-}
-
-fn make_write(mut stream: TcpStream) -> (Sender<Message>, thread::JoinHandle<io::Result<()>>) {
-    let (writer_sender, writer_receiver) = bounded::<Message>(0);
-    let writer = thread::spawn(move || {
-        writer_receiver.into_iter().try_for_each(|it| it.write(&mut stream)).unwrap();
-        Ok(())
-    });
-    (writer_sender, writer)
-}