use failure::Error;
use futures::{Future, Stream};
use tokio::{io::AsyncRead, net::UnixListener};

fn main() -> Result<(), Error> {
    let listener = UnixListener::bind("socket.sock")?;

    tokio::run(
        listener
            .incoming()
            .for_each(|socket| {
                let (reader, writer) = socket.split();
                tokio::spawn(
                    tokio::io::copy(reader, writer)
                        .map_err(|e| eprintln!("Error copying, {}", e))
                        .map(|(num, _, _)| println!("Copy complete, {}", num)),
                );

                Ok(())
            })
            .map_err(|e| eprintln!("Error: {}", e)),
    );

    Ok(())
}