One of the primary advantage of Stream-oriented processing is the fact that we can apply functional programming primitives on them. In RxCpp parlance, the processing is done using Operators. They are nothing but filters, transformations, aggregations, and reductions on Streams. We have already seen how the map, filter, and take operators work in the previous examples. Let us explore them further.
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);},
[...