use std::net::SocketAddr;
use tokio::prelude::future::Map;
use tokio::sync::mpsc::{channel, Receiver, Sender};
use tokio::{net::TcpListener, prelude::*};

fn main() {
    let addr = "127.0.0.1:8118".parse::<SocketAddr>().unwrap();
    let listener = TcpListener::bind(&addr).expect("unable to bind");
    let (sender, _): (Sender<char>, Receiver<char>) = channel(64);

    tokio::run(
        listener
            .incoming()
            .and_then(|s| tokio::io::read_to_end(s, vec![]))
            .map_err(|e| panic!("failed: {:?}", e))
            .for_each(move |(_socket, buf)| {
                let s = sender.clone();
                println!("Received: {:#?}", buf);
                let c = buf[0] as char;
                if c == 'a' {
                    s.send(c).map_err(|e| panic!("failed: {:?}", e)).map(|_| ())
                } else {
                    Future::map()  // What to do now?
                }
            }),
    );
}