extern crate tokio;

use tokio::prelude::*;
use tokio::net::TcpListener;
use std::io::BufReader;

const BIND_ADDR: &'static str = "127.0.0.1:3333";

fn main() {
    let addr = BIND_ADDR.parse().unwrap();
    let listener = TcpListener::bind(&addr)
        .expect("can't bind");

    let server = listener.incoming()
        .map_err(|e| eprintln!("accept failed = {:?}", e))
        .for_each(|stream| {

            let f = tokio::io::read_until(
                BufReader::new(stream), 0x12, Vec::new());

            let task = f.and_then(|t| {
                println!("{:?}", t);
                Ok(())
            });

            tokio::spawn(task);
            Ok(())
        });

    tokio::run(server);
}