|
ReactivePlusPlus
ReactiveX implementation for C++20
|
| rpp | |
| 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 |
| Transforming Operators | Transforming operators are operators that transform items provided by observable |
| Filtering Operators | Filtering operators are operators that emit only part of items that satisfies some condition |
| Conditional Operators | Conditional operators are operators that emit items based on some condition including condition of items from other observables |
| Combining Operators | Combining operators are operators that combines emissions of multiple observables into same observable by some rule |
| Utility Operators | Utility operators are operators that provide some extra functionality without changing of original values, but changing of behaviour |
| Connectable Operators | Connectable operators are operators that provide extra functionality for multicasting of controlling of subscription |
| Aggregate Operators | Aggregate operators are operators that operate on the entire sequence of items emitted by an Observable |
| Error Handling Operators | Operators that help to recover from error notifications from an Observable |
| Creational Operators | Creational operators are operators that create new observable |
| 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 |
| Extensions | Extensions for ReactivePlusPlus library for 3rd party libraries |
| rppasio | RppAsio is extension of RPP which enables support of boost-asio library |
| Asio Schedulers | Scheduler is the way to introduce multi-threading in your application via RPP |
| rppgrpc | RppGrpc is extension of RPP which enables support of grpc library |
| gRPC reactors | Reactors for gRPC to connect it to RPP properly |
| rppqt | RppQt is extension of RPP which enables support of Qt library |
| QT Operators | QT Operators is set of RPP operators but applied to QObjects |
| QT Creational Operators | QT creational operators are operators that create new observable from QObjects |
| QT Schedulers | Scheduler is the way to introduce multi-threading in your application via RPP |