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

fix tests

This commit is contained in:
fakeshadow 2021-03-30 21:11:53 +08:00
parent 1554f39e9d
commit acaff5e225
1 changed files with 24 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -22,20 +22,21 @@ fn test_bind() {
let (tx, rx) = mpsc::channel(); let (tx, rx) = mpsc::channel();
let h = thread::spawn(move || { let h = thread::spawn(move || {
let sys = actix_rt::System::new(); let system = actix_rt::System::new();
sys.block_on(async { system.block_on(async {
actix_rt::spawn(async move { let server = Server::build()
let _ = Server::build() .workers(1)
.workers(1) .disable_signals()
.disable_signals() .bind("test", addr, move || fn_service(|_| ok::<_, ()>(())))
.bind("test", addr, move || fn_service(|_| ok::<_, ()>(()))) .unwrap()
.unwrap() .run();
.run() let _ = tx.send(actix_rt::System::current());
.await; let _ = actix_rt::spawn(async move {
let _ = server.await;
}); });
}); });
let _ = tx.send(actix_rt::System::current());
let _ = sys.run(); system.run()
}); });
let sys = rx.recv().unwrap(); let sys = rx.recv().unwrap();
@ -54,18 +55,20 @@ fn test_listen() {
let sys = actix_rt::System::new(); let sys = actix_rt::System::new();
let lst = net::TcpListener::bind(addr).unwrap(); let lst = net::TcpListener::bind(addr).unwrap();
sys.block_on(async { sys.block_on(async {
let server = Server::build()
.disable_signals()
.workers(1)
.listen("test", lst, move || fn_service(|_| ok::<_, ()>(())))
.unwrap()
.run();
let _ = tx.send(actix_rt::System::current());
actix_rt::spawn(async move { actix_rt::spawn(async move {
let _ = Server::build() let _ = server.await;
.disable_signals()
.workers(1)
.listen("test", lst, move || fn_service(|_| ok::<_, ()>(())))
.unwrap()
.run()
.await;
}); });
}); });
let _ = tx.send(actix_rt::System::current()); sys.run()
let _ = sys.run();
}); });
let sys = rx.recv().unwrap(); let sys = rx.recv().unwrap();