Process each chunk of a stream via the supplied function - View it on GitHub