create a transform stream that runs a function over all collected elements - View it on GitHub