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

use FnOnce instead of Fn

This commit is contained in:
fakeshadow 2020-12-23 03:18:58 +08:00
parent 6012bcf941
commit 54e8b6628c
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
actix-server/src/builder.rs
View File

@ -299,7 +299,7 @@ impl ServerBuilder {
pub fn on_stop<F, Fut>(mut self, future: F) -> Self pub fn on_stop<F, Fut>(mut self, future: F) -> Self
where where
F: Fn() -> Fut + 'static, F: FnOnce() -> Fut + 'static,
Fut: Future<Output = ()>, Fut: Future<Output = ()>,
{ {
self.on_stop = Box::pin(async move { future().await }); self.on_stop = Box::pin(async move { future().await });

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

@ -201,11 +201,8 @@ fn test_on_stop() {
let srv: Server = Server::build() let srv: Server = Server::build()
.backlog(100) .backlog(100)
.disable_signals() .disable_signals()
.on_stop(move || { .on_stop(|| async move {
let bool = bool.clone(); bool.store(true, Ordering::SeqCst);
async move {
bool.store(true, Ordering::SeqCst);
}
}) })
.bind("test", addr, move || { .bind("test", addr, move || {
fn_service(|io: TcpStream| async move { fn_service(|io: TcpStream| async move {