berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

Reduce usage of thread sleep

This commit is contained in:
fakeshadow 2021-04-28 06:09:57 +08:00
parent aaeaa0aebd
commit a0b6d58e00
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
actix-server/tests/test_server.rs
View File

@ -67,7 +67,6 @@ fn test_listen() {
let handle = rx.recv().unwrap(); let handle = rx.recv().unwrap();
thread::sleep(Duration::from_millis(500));
assert!(net::TcpStream::connect(addr).is_ok()); assert!(net::TcpStream::connect(addr).is_ok());
let _ = handle.stop(true); let _ = handle.stop(true);
let _ = h.join().unwrap(); let _ = h.join().unwrap();
@ -138,7 +137,6 @@ fn test_start() {
thread::sleep(Duration::from_millis(100)); thread::sleep(Duration::from_millis(100));
assert!(net::TcpStream::connect(addr).is_err()); assert!(net::TcpStream::connect(addr).is_err());
thread::sleep(Duration::from_millis(100));
sys.stop(); sys.stop();
let _ = h.join(); let _ = h.join();
} }
@ -184,7 +182,6 @@ fn test_configure() {
}); });
let (server, sys) = rx.recv().unwrap(); let (server, sys) = rx.recv().unwrap();
thread::sleep(Duration::from_millis(500));
assert!(net::TcpStream::connect(addr1).is_ok()); assert!(net::TcpStream::connect(addr1).is_ok());
assert!(net::TcpStream::connect(addr2).is_ok()); assert!(net::TcpStream::connect(addr2).is_ok());