two_intervals/
two_intervals.rs

1extern crate futures;
2extern crate tk_easyloop;
3
4use std::time::Duration;
5use futures::{Stream, Future};
6use tk_easyloop::{run_forever, interval, spawn};
7
8fn main() {
9
10    run_forever(|| {
11        spawn(interval(Duration::new(1, 0))
12            .for_each(|()| {
13                println!("1 sec interval");
14                Ok(())
15            }).map_err(|_| ()));
16        spawn(interval(Duration::from_millis(500))
17            .for_each(|()| {
18                println!("Half second interval");
19                Ok(())
20            }).map_err(|_| ()));
21        Ok::<_, ()>(())
22    }).unwrap();
23}