add support for multithread buffer sending

src/dispatcher.rs

@@ -1,5 +1,6 @@
 use std::io::BufReader;
 use std::net::TcpStream;
+use std::thread;
 use std::time::{Duration, SystemTime};
 use std::{fs::File, io::Write};
 
@@ -34,27 +35,31 @@ impl Dispatcher {
                 continue;
             }
 
-            let mut sock = TcpStream::connect(addr).expect("Failed to connect");
+            let source = source.clone();
 
-            while offset < duration {
+            thread::spawn(move || {
-                let sound_data = source
+                let mut sock = TcpStream::connect(addr).expect("Failed to connect");
-                    .clone()
-                    .skip_duration(offset)
-                    .take_duration(chunk_len)
-                    .collect::<Vec<i16>>();
 
-                offset += chunk_len;
+                while offset < duration {
+                    let sound_data = source
+                        .clone()
+                        .skip_duration(offset)
+                        .take_duration(chunk_len)
+                        .collect::<Vec<i16>>();
 
-                let msg = Message::PlaySound(PlaySound {
+                    offset += chunk_len;
-                    timestamp: (now + offset).as_micros(),
-                    channels: channels,
-                    sample_rate: sample_rate,
-                    sound_data: sound_data,
-                });
 
-                let buf = bincode::serialize(&msg).expect("Failed to serialize");
+                    let msg = Message::PlaySound(PlaySound {
-                sock.write_all(&buf).unwrap();
+                        timestamp: (now + offset).as_micros(),
-            }
+                        channels: channels,
+                        sample_rate: sample_rate,
+                        sound_data: sound_data,
+                    });
+
+                    let buf = bincode::serialize(&msg).expect("Failed to serialize");
+                    sock.write_all(&buf).unwrap();
+                }
+            });
         }
     }
 }

src/main.rs

@@ -15,7 +15,7 @@ mod ui_app;
 
 fn main() -> eframe::Result {
     let options = eframe::NativeOptions {
-        viewport: egui::ViewportBuilder::default().with_inner_size([1000.0, 1000.0]),
+        viewport: egui::ViewportBuilder::default().with_inner_size([700.0, 400.0]),
         ..Default::default()
     };
 

src/ui_app.rs

@@ -46,15 +46,22 @@ impl eframe::App for UIApp {
             if ui.button("Add address").clicked() {
                 self.addresses.push("localhost:3000".to_owned());
             }
+            ui.add_space(25.0);
             ui.separator();
+            ui.add_space(25.0);
 
            if ui.button("Pick file").clicked() {
-                if let Some(file) = FileDialog::new().set_directory("/").pick_file() {
+                let file = FileDialog::new().pick_file();
-                    self.picked_file = Some(file);
+                if !file.is_none() {
+                    self.picked_file = file;
                 }
             }
+            
             ui.label(format!("Picked file: {:?}", self.picked_file));
+
+            ui.add_space(25.0);
             ui.separator();
+            ui.add_space(25.0); 
 
             if ui.button("Play sound").clicked() {
                 if let Some(path) = &self.picked_file {