One more implementation of ReactiveX approach in C++ with care about performance and templates in mind - View it on GitHub