Enum interval_task::runner::Task

pub enum Task {
    TaskFn(Box<dyn FnTask + Send + Sync>),
    TaskFnMut(Box<dyn FnMutTask + Send + Sync>),
}

Variants

TaskFn(Box<dyn FnTask + Send + Sync>)

TaskFnMut(Box<dyn FnMutTask + Send + Sync>)

Implementations

impl Task

pub fn new_fn_task(t: impl FnTask + Send + Sync + 'static) -> Task

pub fn new_fn_mut_task(t: impl FnMutTask + Send + Sync + 'static) -> Task

Examples found in repository

examples/runner.rs (line 28)

fn external_close_example() {
    use interval_task::runner::{self, ExternalRunnerExt, FnMutTask, Task};

    struct TestTask(u32, async_channel::Sender<u8>);
    impl FnMutTask for TestTask {
        fn call_mut(&mut self) {
            if self.0 == 119 {
                self.1.send_blocking(0).unwrap();
            } else {
                self.0 += 1
            }
        }
    }

    let mut runner = runner::new_external_close_runner(Duration::from_micros(1_000_000 / 120));
    let (s, r) = async_channel::bounded(1);
    runner.set_task(Task::new_fn_mut_task(TestTask(0, s)));
    runner.start().unwrap();
    let start = Instant::now();
    r.recv_blocking().unwrap();
    println!("Elapsed: {:?}", start.elapsed());
    runner.close().unwrap();
}

Trait Implementations

impl TaskExt<()> for Task

fn get_call<'a>(&'a mut self) -> Box<dyn FnMut() + Send + Sync + 'a>

impl Send for Task

impl Sync for Task