fn main() {
    let addr = "127.0.0.1:10228".parse().unwrap();
    let listener = TcpListener::bind(&addr)
        .expect("Unable to bind");

    let server = listener.incoming().for_each(move |mut sock| {
        let (reader, writer) = sock.split();
        let buffer = Vec::new();

        let handle_conn = tokio::io::read(reader, buffer)
            .and_then(move |(r, b, len)| {
                info!("Got {:?}\namount of bytes: {}", b, len);
                Ok(())
            }).map_err(|e| {error!("{}", e)});
        tokio::spawn(handle_conn);
        Ok(())
    }).map_err(|e| {error!("{}", e)});

    tokio::run(server);
}