C++ Reactive Programming

The average Operator

The average Operator computes arithmetic mean of values from Observable Streams. The other statistical Operators supported include:

• Min
• Max
• Count
• Sum

The following program just demonstrates the average Operator. The schema is the same for other operators in the preceding list:

//----------- Average.cpp 
#include "rxcpp/rx.hpp" 
#include "rxcpp/rx-test.hpp" 
#include <ioStream> 
int main() { 
    auto values = rxcpp::observable<>::range(1, 20).average(); 
    values.subscribe( 
            [](double v){printf("average: %lfn", v);}, 
            [](){printf("OnCompletedn");}); 
}