Disable windows portions for now

Author: IsaacShelton

src/daemon/src/connection.rs

@@ -1,9 +1,9 @@
 use lsp_message::LspMessage;
-use std::io::BufReader;
 #[cfg(target_family = "unix")]
 use std::os::unix::net::UnixStream;
 #[cfg(target_family = "unix")]
-use std::{io, sync::Mutex};
+use std::sync::Mutex;
+use std::{io, io::BufReader};
 
 pub struct Connection {
     #[cfg(target_family = "unix")]
@@ -12,12 +12,24 @@ pub struct Connection {
 
 impl Connection {
     pub fn wait_for_message(&self) -> io::Result<Option<LspMessage>> {
-        let stream = self.stream.lock().unwrap();
-        LspMessage::read(&mut BufReader::new(&*stream))
+        #[cfg(target_family = "unix")]
+        {
+            let stream = self.stream.lock().unwrap();
+            LspMessage::read(&mut BufReader::new(&*stream))
+        }
+
+        #[cfg(target_family = "windows")]
+        panic!("Windows is not supported")
     }
 
     pub fn send(&self, message: LspMessage) -> io::Result<()> {
-        let stream = self.stream.lock().unwrap();
-        message.write(&mut &*stream)
+        #[cfg(target_family = "unix")]
+        {
+            let stream = self.stream.lock().unwrap();
+            message.write(&mut &*stream)
+        }
+
+        #[cfg(target_family = "windows")]
+        panic!("Windows is not supported")
     }
 }

src/daemon/src/lib.rs

@@ -6,9 +6,10 @@ mod queue;
 pub use crate::{connection::Connection, daemon::Daemon};
 use lsp_message::LspMessage;
 pub use queue::*;
+#[cfg(target_family = "unix")]
+use std::os::unix::net::{SocketAddr, UnixStream};
 use std::{
     io::{self, BufReader, ErrorKind},
-    os::unix::net::{SocketAddr, UnixStream},
     sync::Arc,
     time::Duration,
 };
@@ -51,8 +52,12 @@ pub fn main_loop(daemon: Daemon) -> io::Result<()> {
 
         std::thread::sleep(Duration::from_millis(50));
     }
+
+    #[cfg(target_family = "windows")]
+    panic!("Windows is not supported")
 }
 
+#[cfg(target_family = "unix")]
 fn handle_client(_daemon: Arc<Daemon>, stream: UnixStream, address: SocketAddr) {
     log::info!("Accepted client {:?} {:?}", stream, address);
     std::thread::sleep(Duration::from_millis(50));