Added delay to Processing::Partial

src/action.rs

@@ -2,9 +2,11 @@ use crate::state::{State};
 
 use message_io::network::{Network};
 
+use std::time::{Duration};
+
 pub enum Processing {
     Completed,
-    Partial,
+    Partial(Duration),
 }
 
 pub trait Action: Send {

src/application.rs

@@ -279,8 +279,8 @@ impl<'a> Application<'a> {
     fn process_action(&mut self, mut action: Box<dyn Action>) {
         match action.process(&mut self.state, &mut self.network) {
             Processing::Completed => (),
-            Processing::Partial => {
-                self.event_queue.sender().send(Event::Action(action));
+            Processing::Partial(delay) => {
+                self.event_queue.sender().send_with_timer(Event::Action(action), delay);
             }
         }
     }

src/commands/send_file.rs

@@ -8,6 +8,7 @@ use message_io::network::{Network};
 
 use std::path::{Path};
 use std::io::{Read};
+use std::time::{Duration};
 
 pub struct SendFileCommand;
 
@@ -64,7 +65,9 @@ impl Action for SendFile {
         let (bytes_read, chunk, processing) = match self.file.read(&mut data) {
             Ok(0) => (0, Chunk::End, Processing::Completed),
             Ok(bytes_read) => {
-                (bytes_read, Chunk::Data(data[..bytes_read].to_vec()), Processing::Partial)
+                // We add a minor delay to introduce a rate in the sending.
+                let processing = Processing::Partial(Duration::from_micros(100));
+                (bytes_read, Chunk::Data(data[..bytes_read].to_vec()), processing)
             }
             Err(error) => {
                 format!("Error sending file. error: {}", error).report_err(state);

src/commands/send_stream/linux.rs

@@ -11,6 +11,8 @@ use v4l::buffer::Type;
 use v4l::io::traits::CaptureStream;
 use v4l::video::traits::Capture;
 
+use std::time::{Duration};
+
 // Send Stream logic
 
 pub struct SendStreamCommand;
@@ -88,7 +90,7 @@ impl Action for SendStream {
         let message = NetMessage::Stream(Some((data, self.width, self.height)));
         network.send_all(state.all_user_endpoints(), message);
 
-        Processing::Partial
+        Processing::Partial(Duration::from_millis(16)) //~60fps - delay of computation
     }
 }