C++ Reactive Programming

Writing a custom creational operator

The majority of RxCpp operator functions accept Observables and return an Observable to achieve composition of operators. We need to do some extra work to make the composition in a chainable fashion (in the next section, we will cover lift<t> and the topic of adding operators to the [observable<T>] Observable in the RxCpp library). The operators we implement in this section will help us create an Observable from the input data. We can create an Observable stream of any type,from individual value of the type, from a range of values, from an iterator to a STL container, from another Observable, and so on. Let's discuss an example program that accepts an STL container and creates an Observable, followed by ...