C++ Reactive Programming

Working with Schedulers

We have already learned about Observables, Operators, and Observers , in the above section. We now know that, between Observables and Observers, we can apply standard Rx Operators to filter and transform streams. In the case of Functional Programming, we write immutable functions (functions without side-effects) and a consequence of immutability is the potential for an out-of-order execution. The order in which we execute a function/functor does not matter, if we can guarantee that the input to an Operator is never modified. Since an Rx program will be manipulating multiple Observables  and Observers, we can delegate the task of choosing the execution order to a Scheduler module. By default, Rxcpp is single threaded. ...