Reactive Extensions (c++ template version)