stream.Transform with parallel chunk processing - View it on GitHub