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

narrow rt features

This commit is contained in:
Rob Ede 2021-03-29 11:13:30 +01:00
parent 68d3432801
commit c926d1057f
No known key found for this signature in database
GPG Key ID: 97C636207D3EF933
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
actix-codec/Cargo.toml
View File

@ -16,8 +16,8 @@ name = "actix_codec"
path = "src/lib.rs" path = "src/lib.rs"
[dependencies] [dependencies]
actix-rt = { version = "2.0.0", default-features = false }
actix-service = "2.0.0-beta.5" actix-service = "2.0.0-beta.5"
actix-rt = "2.0.0"
bitflags = "1.2.1" bitflags = "1.2.1"
bytes = "1" bytes = "1"

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

@ -22,14 +22,15 @@ fn test_bind() {
let h = thread::spawn(move || { let h = thread::spawn(move || {
let sys = actix_rt::System::new(); let sys = actix_rt::System::new();
let srv = sys.block_on(lazy(|_| { let srv = sys.block_on(async {
Server::build() 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((srv, actix_rt::System::current())); let _ = tx.send((srv, actix_rt::System::current()));
let _ = sys.run(); let _ = sys.run();
}); });
@ -82,7 +83,7 @@ fn test_start() {
let h = thread::spawn(move || { let h = thread::spawn(move || {
let sys = actix_rt::System::new(); let sys = actix_rt::System::new();
let srv = sys.block_on(lazy(|_| { let srv = sys.block_on(async {
Server::build() Server::build()
.backlog(100) .backlog(100)
.disable_signals() .disable_signals()
@ -95,7 +96,7 @@ fn test_start() {
}) })
.unwrap() .unwrap()
.run() .run()
})); });
let _ = tx.send((srv, actix_rt::System::current())); let _ = tx.send((srv, actix_rt::System::current()));
let _ = sys.run(); let _ = sys.run();
@ -151,7 +152,7 @@ fn test_configure() {
let h = thread::spawn(move || { let h = thread::spawn(move || {
let num = num2.clone(); let num = num2.clone();
let sys = actix_rt::System::new(); let sys = actix_rt::System::new();
let srv = sys.block_on(lazy(|_| { let srv = sys.block_on(async {
Server::build() Server::build()
.disable_signals() .disable_signals()
.configure(move |cfg| { .configure(move |cfg| {
@ -174,7 +175,8 @@ fn test_configure() {
.unwrap() .unwrap()
.workers(1) .workers(1)
.run() .run()
})); });
let _ = tx.send((srv, actix_rt::System::current())); let _ = tx.send((srv, actix_rt::System::current()));
let _ = sys.run(); let _ = sys.run();
}); });