ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp

Topics

 Disposables
 Disposable is handle/resource passed from observable to observer via the set_upstream method. Observer disposes this disposable when it wants to unsubscribe from observable.
 
 Observables
 Observable is the source of any Reactive Stream.
 
 Observers
 
 Operators
 Operators modify observables and extend them with custom logic.
 
 Schedulers
 Scheduler is the way to introduce multi-threading in your application via RPP.
 
 Subjects
 Observable is the observable and observer at the same time. Uses as a bridge and for manual sending of values.
 

Detailed Description

ReactivePlusPlus is reactive programming library for C++20 language inspired by "official implementation" (RxCpp) and original idea (ReactiveX) that only depends on standard library and C++20 features (mostly on concepts).

Example:
| rpp::operators::take_while([](char v) { return v != '0'; })
| rpp::operators::filter(std::not_fn(&::isdigit))
| rpp::operators::map(&::toupper)
| rpp::operators::subscribe([](char v) { std::cout << v; });