a modded io.Pipe for passing a stream of values through - View it on GitHub