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

use instant returned by tokio interval

This commit is contained in:
fakeshadow 2021-02-12 13:24:00 -08:00
parent 9e802059f3
commit 999bbb14f0
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
actix-http/src/config.rs
View File

@ -249,7 +249,7 @@ impl DateService {
fn new() -> Self { fn new() -> Self {
// shared date and timer for DateService and update async task. // shared date and timer for DateService and update async task.
let current = Rc::new(Cell::new((Date::new(), Instant::now()))); let current = Rc::new(Cell::new((Date::new(), Instant::now())));
let current_clone = current.clone(); let current_clone = Rc::clone(&current);
// spawn an async task sleep for 500 milli and update current date/timer in a loop. // spawn an async task sleep for 500 milli and update current date/timer in a loop.
// handle is used to stop the task on DateService drop. // handle is used to stop the task on DateService drop.
let handle = actix_rt::spawn(async move { let handle = actix_rt::spawn(async move {
@ -258,11 +258,8 @@ impl DateService {
let mut interval = interval(Duration::from_millis(500)); let mut interval = interval(Duration::from_millis(500));
loop { loop {
// TODO: consider use the Instant returned by interval stream let now = interval.tick().await;
// (If it's accurate enough)
let _now = interval.tick().await;
let date = Date::new(); let date = Date::new();
let now = Instant::now();
current_clone.set((date, now)); current_clone.set((date, now));
} }
}); });