Tokio Interval

extern crate futures;
extern crate tokio;

use futures::{Future, Stream};
use tokio::timer::*;
use std::time::{Duration, Instant};


fn main() {
    let ten_millis = Duration::from_millis(150);
    let interval_a = Interval::new(Instant::now(), ten_millis);
    let interval_b = Interval::new(Instant::now(), ten_millis);
    
    let task = interval_a
        .for_each(|_x| {
            println!("");
            println!("TestString");
            Ok(())
        })
        .map_err(|_| (()) );

    tokio::run(task);
}