pipeline to parallel xforms then async/reduce to aggregate result from out chan