From bf2990121b46363ca4f6a10114504d70fe88a230 Mon Sep 17 00:00:00 2001
From: dvkt <c@dvkt.io>
Date: Sun, 22 Dec 2019 18:18:23 -0800
Subject: [PATCH] it lives

---
 src/main.rs | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 5a3ba00..6965496 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -30,13 +30,19 @@ async fn listen(addr: impl ToSocketAddrs) -> Result<()> {
     Ok(())
 }
 
-async fn client_loop(stream: TcpStream) -> Result<()> {
+async fn client_loop(mut stream: TcpStream) -> Result<()> {
     let reader = BufReader::new(&stream);
     let mut lines = reader.lines();
 
-    while let Some(line) = lines.next().await {
-        let line = line?;
+    if let Some(Ok(line)) = lines.next().await {
         println!("-> client sent: {:?}", line);
+        respond(&mut stream, &line).await?;
     }
     Ok(())
 }
+
+async fn respond(stream: &mut TcpStream, selector: &str) -> Result<()> {
+    let response = format!("3You sent: {}", selector);
+    stream.write_all(response.as_bytes()).await?;
+    Ok(())
+}