Function interval_task::channel::new_blocking

pub fn new_blocking(
    interval: Duration,
) -> (Sender<u8>, Receiver<u8>, Runner<Task>)

Create a runner::Runner. Signals every interval and waits for TASK_DONE signal.

Examples found in repository

examples/channel.rs (line 16)

fn blocking() {
    let (s, r, mut runner) = channel::new_blocking(Duration::from_micros(1_000_000 / 120));
    runner.start().unwrap();
    let start = Instant::now();
    for _ in 0..120 {
        r.recv_blocking().unwrap();
        s.send_blocking(TASK_DONE).unwrap();
    }
    println!("Elapsed: {:?}", start.elapsed());
    runner.close().unwrap();
}