gistfile1.txt

fn writeall_stdout(socket: TcpStream) -> IoFuture<()> {
    let iter = iter::repeat(()).map(|()| Ok(()));
    stream::iter(iter).fold(socket, move |socket, ()| {
        let buf = vec![0;1024];
        tokio_core::io::read(socket, buf).map(|(socket, _, num_bytes)| {
            println!("Read {} bytes", num_bytes);
            socket
        })
    }).map(|_| ()).boxed()
}