-
Book Overview & Buying
-
Table Of Contents
-
Feedback & Rating

C++ Reactive Programming
By :

The RxCpp library provides a declarative threading mechanism, thanks to the robust scheduling subsystem packaged with it. From an Observable, data can be streamed through different paths along the change propagation graph. By giving hints to the Stream processing pipeline, we can schedule the execution in different threads, the same thread, or a background thread. This helps to capture the intent of the programmer much better.
The declarative scheduling model in RxCpp is possible because of the immutability of the Streams in an operator's implementation. A stream operator takes an Observable as a parameter and returns a fresh Observable as the result. The input parameter is not modified. This helps in out-of-order execution. The scheduling subsystem of RxCpp contains the following constructs:
Version 2 of RxCpp borrows its scheduling architecture from the RxJava
system. It relies on Scheduler and Worker idioms used by RxJava...