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

fix clippy

This commit is contained in:
fakeshadow 2021-03-28 21:22:04 +08:00
parent 899d22a98e
commit 29402d25b7
1 changed files with 15 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
actix-server/src/test_server.rs
View File

@ -48,19 +48,12 @@ impl TestServer {
// run server in separate thread
thread::spawn(move || {
let sys = System::new();
sys.block_on(async {
actix_rt::spawn(async move {
let _ = factory(Server::build())
.workers(1)
.disable_signals()
.run()
.await;
})
});
System::new().block_on(async {
let server = factory(Server::build()).workers(1).disable_signals().run();
tx.send(System::current()).unwrap();
tx.send(System::current()).unwrap();
sys.run()
server.await
})
});
let system = rx.recv().unwrap();
@ -83,18 +76,17 @@ impl TestServer {
let local_addr = tcp.local_addr().unwrap();
sys.block_on(async {
actix_rt::spawn(async move {
let _ = Server::build()
.listen("test", tcp, factory)
.unwrap()
.workers(1)
.disable_signals()
.run()
.await;
});
let server = Server::build()
.listen("test", tcp, factory)
.unwrap()
.workers(1)
.disable_signals()
.run();
tx.send((System::current(), local_addr)).unwrap();
});
sys.run()
server.await
})
});
let (system, addr) = rx.recv().unwrap();