C++ Reactive Programming

Using the lift<t> operator to write a custom operator

The RxCpp library has an operator as part of the observable<T> implementation, called lift (lift<t>). In fact, it can be called a meta-operator as it has the capability to convert a unary function or functor that takes an ordinary variable (int, float, double, struct, and so on) to be compatible for processing observable<T> Streams. The RxCpp implementation of observable<T>::lift expects a Lambda that takes rxcpp::subscriber<T> as a parameter, and within the body of the Lambda, we can apply an action (a Lambda or a function). In this section, one can get an overview of the purpose of the lift<t> operator.

The lift operator takes any function or Lambda that will take a Subscriber for ...