Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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);
- }
Add Comment
Please, Sign In to add comment