(&self)
| 208 | } |
| 209 | |
| 210 | pub fn next_event_time(&self) -> Option<DateTime<Utc>> { |
| 211 | let lowest_interval = self |
| 212 | .loaded_intervals |
| 213 | .iter() |
| 214 | .filter(|(name, _)| { |
| 215 | // filter timers already triggered that were waiting to hear back from being run |
| 216 | !self |
| 217 | .pending |
| 218 | .iter() |
| 219 | .any(|pending| name.identifies_timer(pending)) |
| 220 | }) |
| 221 | .min_by(|(_, a), (_, b)| a.next_run.cmp(&b.next_run)); |
| 222 | |
| 223 | lowest_interval.map(|(_, v)| v.next_run_with_cron_smear(self.cron_smear)) |
| 224 | } |
| 225 | } |
| 226 | |
| 227 | #[derive(Clone)] |
no test coverage detected