tokio-proto 0.1.0

extern crate futures;
extern crate tokio_proto;
extern crate tokio_core;

use futures::stream::Stream;
use tokio_core::reactor::Core;
use tokio_core::net::TcpListener;

pub fn main() {
    // Create a new loop
    let mut lp = Core::new().unwrap();

    // Bind to port 4000
    let addr = "0.0.0.0:4000".parse().unwrap();

    // Create the new TCP listener
    let listener = TcpListener::bind(&addr, &lp.handle()).unwrap();

    // Accept each incoming connection
    let srv = listener.incoming().for_each(|socket| {
        // Do something with the socket
        println!("{:#?}", socket);
        Ok(())
    });

    println!("listening on {:?}", addr);

    lp.run(srv).unwrap();
}