C++ Reactive Programming

A simple Observable/Observer interaction

Let's write a simple program that help us understand the programming model of the RxCpp library. In this particular program, we will have an Observable Stream and an Observer that subscribes to the Stream. We will generate a series of numbers from 1 to 12, using a range object. After creating the range of values and an Observable over them, we will attach them together When we execute the program, it will print a series of numbers to the console. Finally, a literal string ( "Oncompleted") will also be printed on the console. :

////////// // First.cpp // g++ -I<PathToRxCpplibfoldersrc> First.cpp #include "rxcpp/rx.hpp" #include <ioStream> int main() { //------------- Create an Observable.. a Stream ...