lucas/lool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: 💄 linting

Browse Source
This commit is contained in:
Lucas Colombo 2024-04-23 12:20:06 -03:00
parent 89ad7be68b
commit aed69c2a47
Signed by: lucas
GPG Key ID: EF34786CFEFFAE35
2 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
examples/sched_tokio_future.rs
View File

@ -18,12 +18,18 @@ async fn main() -> Result<()> {
let mut sched = Scheduler::new(); let mut sched = Scheduler::new();
log::debug!("scheduler created"); log::debug!("scheduler created");
let now = chrono::Local::now(); let now = chrono::Local::now();
let handler = sched.schedule_fut("test-task", async move { let handler = sched
println!("I'm running at {}", &now.format("%Y-%m-%d %H:%M:%S")); .schedule_fut(
}, recur(ruleset().at_second(0))).await; "test-task",
async move {
println!("I'm running at {}", &now.format("%Y-%m-%d %H:%M:%S"));
},
recur(ruleset().at_second(0)),
)
.await;
sleep(std::time::Duration::from_secs(1)).await; sleep(std::time::Duration::from_secs(1)).await;

7
lib/sched/rules/recurrent/rule_unit.rs
View File

@ -43,12 +43,9 @@ where
value >= *start || value <= *end value >= *start || value <= *end
} }
} else if *start < *end { } else if *start < *end {
value >= *start value >= *start && value <= *end && (value - *start) % *step == T::zero()
&& value <= *end
&& (value - *start) % *step == T::zero()
} else { } else {
(value >= *start || value <= *end) (value >= *start || value <= *end) && (*start - value) % *step == T::zero()
&& (*start - value) % *step == T::zero()
} }
} }
Rule::Many(matcher) => matcher.iter().any(|v| Self::_matches(&Rule::Val(*v), value)), Rule::Many(matcher) => matcher.iter().any(|v| Self::_matches(&Rule::Val(*v), value)),