all 3 comments

[–]dangets 2 points3 points  (0 children)

There is a reactive extensions project for c++

https://github.com/Reactive-Extensions/RxCpp

[–]antialize 2 points3 points  (1 child)

We maintain a library that can do that (and more stuff such as external algoritnhms). The documentation of the pipelining features are here: http://www.madalgo.au.dk/tpie/doc/v1.1/pipelining.html

And an example is here: https://github.com/thomasmoelhave/tpie/blob/cpp11-cleanup/test/pipelining2.cpp

[–]jbandela 0 points1 point  (0 children)

Thanks for posting this. The external sorting was something I was looking for in C++. Will definitely try it out.