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 |