This simple cognative leap fixes delay, switches not syncing, and transferring controls not working

Author: Sequal32

src/server/client.rs

@@ -84,7 +84,9 @@ impl Client {
                         break;
                     }
                     Ok(n) => {
-                        if let Some(data) = transfer.reader.try_read_string(&buf[0..n]) {
+                        transfer.reader.add_buf(&buf[0..n]);
+
+                        while let Some(data) = transfer.reader.try_read_string() {
                             // Deserialize json
                             if let Ok(data) = process_message(&data, None) {
                                 transfer.server_tx.send(data).ok();

src/server/server.rs

@@ -239,9 +239,10 @@ impl Server {
                             to_drop.push(index);
                         }
                         Ok(n) => {
-                            // Append bytes to reader
-                            if let Some(data_string) = client.reader.try_read_string(&buf[0..n]) {
-                                // Parse payload
+                            client.reader.add_buf(&buf[0..n]);
+
+                            while let Some(data_string) = client.reader.try_read_string() {
+                                // Deserialize json
                                 if let Ok(data) = process_message(&data_string, Some(client.name.clone())) {
                                     to_write.push((index, data, data_string));
                                 }
@@ -331,7 +332,7 @@ impl Server {
                 }
 
                 if should_stop {break}
-                sleep(Duration::from_millis(10));
+                sleep(Duration::from_millis(5));
             }
         });
     }

src/server/util.rs

@@ -68,9 +68,11 @@ impl PartialReader {
         }
     }
 
-    pub fn try_read_string(&mut self, buf: &[u8]) -> Option<String> {
+    pub fn add_buf(&mut self, buf: &[u8]) {
         self.buffer.extend_from_slice(buf);
-        
+    }
+
+    pub fn try_read_string(&mut self) -> Option<String> {
         if let Some(index) = self.buffer.iter().position(|&x| x == 0x0a) {
             let result_string = String::from_utf8(self.buffer[0..index + 1].to_vec()).unwrap();
             self.buffer.drain(0..index + 1);