Struct ScheduledTask 

pub struct ScheduledTask { /* private fields */ }

A task to run on a schedule.

Implementations

impl ScheduledTask

pub fn new( schedule: ScheduleAt, task: Box<dyn Fn() -> Pin<Box<dyn Future<Output = ()>>> + Send + 'static>, ) -> Result<Self, &'static str>

Create a new scheduled task.

If the schedule includes a Duration less than 0, returns an error.

Examples found in repository

examples/schedule.rs (lines 10-13)

fn main() {
    let periodic_task = ScheduledTask::new(
        ScheduleAt::Interval(Duration::seconds(4)),
        task!(async { println!("You'll see me every four seconds") })
    ).unwrap();

    let onetime_task = ScheduledTask::new(
        ScheduleAt::DateTime(Utc::now() + Duration::seconds(15)),
        task!(task2())
    ).unwrap();

    let daily_task = ScheduledTask::new(
        ScheduleAt::Daily(Time::from_hms(01, 23, 45)),
        task!(async { println!("Hello"); })
    ).unwrap();

    let schedule = Schedule::builder()
        .tasks([
            periodic_task,
            onetime_task,
            daily_task,
        ])
        .wake_interval(Duration::seconds(1)).unwrap()
        .build();

    schedule.run();

    // run() exits immediately, so we need to wait a bit.
    std::thread::sleep(Duration::seconds(30).to_std().unwrap());
}