From cb58696682394e017c2a47802580cfa88ee29f2f Mon Sep 17 00:00:00 2001 From: fakeshadow <24548779@qq.com> Date: Tue, 29 Dec 2020 05:15:22 +0800 Subject: [PATCH] fix clippy. add test for join_all --- actix-server/src/lib.rs | 14 ++++++++++++++ actix-server/tests/test_server.rs | 4 ++-- 2 files changed, 16 insertions(+), 2 deletions(-) diff --git a/actix-server/src/lib.rs b/actix-server/src/lib.rs index 79b5d57b..64aca7e4 100644 --- a/actix-server/src/lib.rs +++ b/actix-server/src/lib.rs @@ -125,3 +125,17 @@ impl Future for JoinAll { } } } + +#[cfg(test)] +mod test { + use super::*; + + #[actix_rt::test] + async fn test_join_all() { + let futs = vec![ready(Ok(1)), ready(Err(3)), ready(Ok(9))]; + let mut res = join_all(futs).await.into_iter(); + assert_eq!(Ok(1), res.next().unwrap()); + assert_eq!(Err(3), res.next().unwrap()); + assert_eq!(Ok(9), res.next().unwrap()); + } +} diff --git a/actix-server/tests/test_server.rs b/actix-server/tests/test_server.rs index 1f567934..2604df74 100644 --- a/actix-server/tests/test_server.rs +++ b/actix-server/tests/test_server.rs @@ -55,9 +55,9 @@ fn test_listen() { .workers(1) .listen("test", lst, move || fn_service(|_| ok::<_, ()>(()))) .unwrap() - .start() + .start(); + let _ = tx.send(actix_rt::System::current()); }); - let _ = tx.send(actix_rt::System::current()); let _ = sys.run(); }); let sys = rx.recv().unwrap();