Rust tokio/futures playground

minimal.rs

extern crate futures;
extern crate tokio_core;

use futures::{Future, Poll, Async};
use futures::stream::Stream;
use tokio_core::reactor::Core;

struct SendNotice;
impl Stream for SendNotice {
  type Item = String;
  type Error = io::Error;

  fn poll(&mut self) -> Poll<Option<Self::Item>, io::Error> {
    println!("polled...");
    Ok(Async::Ready(Some("test".to_string())))
  }
}

fn main() {
  // create server event loop
  let mut evt_loop = Core::new().unwrap();
  let handle = evt_loop.handle();

  // endless loop of polling and 'doing something'
  let server = SendNotice {}.for_each( |val| {
    println!("do something");
    Ok(())
  });

  evt_loop.run(server).unwrap();
}