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

fix test

This commit is contained in:
fakeshadow 2021-04-28 08:45:23 +08:00
parent af94cf763d
commit 05d2558774
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -99,12 +99,12 @@ fn test_start() {
.unwrap() .unwrap()
.run(); .run();
let _ = tx.send((server.handle(), actix_rt::System::current())); let _ = tx.send(server.handle());
let _ = server.await; let _ = server.await;
}); });
}); });
let (srv, sys) = rx.recv().unwrap(); let srv = rx.recv().unwrap();
let mut buf = [1u8; 4]; let mut buf = [1u8; 4];
let mut conn = net::TcpStream::connect(addr).unwrap(); let mut conn = net::TcpStream::connect(addr).unwrap();
@ -137,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());
sys.stop();
let _ = h.join(); let _ = h.join();
} }
@ -182,13 +181,13 @@ async fn test_max_concurrent_connections() {
})? })?
.run(); .run();
let _ = tx.send((server.handle(), actix_rt::System::current())); let _ = tx.send(server.handle());
server.await server.await
}) })
}); });
let (srv, sys) = rx.recv().unwrap(); let srv = rx.recv().unwrap();
let mut conns = vec![]; let mut conns = vec![];
@ -209,7 +208,6 @@ async fn test_max_concurrent_connections() {
srv.stop(false).await; srv.stop(false).await;
sys.stop();
let _ = h.join().unwrap(); let _ = h.join().unwrap();
} }