allow .run to aggregate stream results
.run: use custom transform function
unused require
listen for finish event when aggregating