It would be cool for the pipelining framework to support parallelization of operations.
The expression pipeline p = x | parallel(a | b | c) | y should instantiate an appropriate number of a | b | c pipes and run them in separate threads. The framework should maintaining the order of elements as well as disregarding the order, and it should keep an appropriately sized internal buffer to amortize the cost of sending items to different threads.
pipeline p = x | parallel(a | b | c) | y
a | b | c
You are right, that would be pretty neat :)
And with the merge 508e301 of the parallel branch into pipelining, I believe we can close this issue.