diff --git a/src/data.rs b/src/data.rs index 4c0af91..70faefb 100644 --- a/src/data.rs +++ b/src/data.rs @@ -35,7 +35,7 @@ impl DownStreamInner { loop { - match data_in.recv_timeout(Duration::from_millis(100)) { + match data_in.recv_timeout(Duration::from_millis(50)) { // DataPipe Received Ok(data_received) => { @@ -198,7 +198,7 @@ impl UpStreamInner { loop { - match data_in.recv_timeout(Duration::from_millis(100)) { + match data_in.recv_timeout(Duration::from_millis(50)) { Ok(data_received) => { @@ -361,7 +361,7 @@ impl, remote_endpoint: String, handlers: InnerHandlers) -> Self { - let _ = ds_tcp_stream.get_ref().set_read_timeout(Some(Duration::from_millis(100))); + let _ = ds_tcp_stream.get_ref().set_read_timeout(Some(Duration::from_millis(50))); FullDuplexTcp { ds_tcp_stream: Arc::new(Mutex::new(ds_tcp_stream)), @@ -548,7 +548,7 @@ impl