|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
| template<rpp::schedulers::constraint::schedulable_handler Handler, typename... Args, rpp::schedulers::constraint::schedulable_fn< Handler, Args... > Fn> | |
| void | schedule (rpp::schedulers::time_point time_point, Fn &&fn, Handler &&handler, Args &&... args) |
| void | drain () |
Public Attributes | |
| std::vector< rpp::schedulers::time_point > | schedulings {} |
| std::vector< rpp::schedulers::time_point > | executions {} |
| rpp::schedulers::details::schedulables_queue< worker_strategy > | queue {} |