Add some concurrency to a transform stream. - View it on GitHub