C++ Reactive Programming

Combining Operators

One of the primary goals of the Rx programming model is to decouple the event source from event sinks. Obviously, there is a need for Operators that can combine Streams from various sources. The RxCpp library implements a set of such Operators. The following table outlines a set of commonly used combining Operators:

Observables	Description
combine_latest	When an item is emitted by either of two Observables, combine the latest item emitted by each Observable via a specified function and emit items based on the results of this function
merge	This combines multiple Observables into one by merging their emissions
start_with	This emits a specified sequence of items before beginning to emit the items ...