From 9c0cc98dc0edb9afc0e1ba91990954096aaba607 Mon Sep 17 00:00:00 2001
From: Ferdinand Schober <ferdinandschober20@gmail.com>
Date: Wed, 27 Dec 2023 21:40:10 +0100
Subject: [PATCH] Remove duplicate code (#60)

---
 src/server.rs | 36 ++----------------------------------
 1 file changed, 2 insertions(+), 34 deletions(-)

diff --git a/src/server.rs b/src/server.rs
index f7c7526..1dc5e67 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -720,44 +720,12 @@ impl Server {
         }
     }
 
-    #[cfg(unix)]
     async fn handle_frontend_stream(
         client_manager: &Rc<RefCell<ClientManager>>,
         frontend: &mut FrontendListener,
         frontend_tx: &Sender<FrontendEvent>,
-        mut stream: ReadHalf<UnixStream>,
-    ) {
-        use std::io;
-
-        let tx = frontend_tx.clone();
-        tokio::task::spawn_local(async move {
-            loop {
-                let event = frontend::read_event(&mut stream).await;
-                match event {
-                    Ok(event) => {
-                        let _ = tx.send(event).await;
-                    }
-                    Err(e) => {
-                        if let Some(e) = e.downcast_ref::<io::Error>() {
-                            if e.kind() == ErrorKind::UnexpectedEof {
-                                return;
-                            }
-                        }
-                        log::error!("error reading frontend event: {e}");
-                        return;
-                    }
-                }
-            }
-        });
-        Self::enumerate(client_manager, frontend).await;
-    }
-
-    #[cfg(windows)]
-    async fn handle_frontend_stream(
-        client_manager: &Rc<RefCell<ClientManager>>,
-        frontend: &mut FrontendListener,
-        frontend_tx: &Sender<FrontendEvent>,
-        mut stream: ReadHalf<TcpStream>,
+        #[cfg(unix)] mut stream: ReadHalf<UnixStream>,
+        #[cfg(windows)] mut stream: ReadHalf<TcpStream>,
     ) {
         use std::io;