|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Classes | |
| class | advanced_call |
Public Member Functions | |
| schedulable_base (const time_point &time_point) | |
| virtual std::optional< time_point > | operator() () noexcept=0 |
| virtual std::optional< advanced_call > | make_advanced_call () noexcept=0 |
| virtual time_point | handle_advanced_call (const advanced_call &) noexcept=0 |
| virtual bool | is_disposed () const noexcept=0 |
| virtual void | on_error (const std::exception_ptr &ep) const =0 |
| time_point | get_timepoint () const |
| void | set_timepoint (const time_point &timepoint) |
| const std::shared_ptr< schedulable_base > & | get_next () const |
| void | set_next (std::shared_ptr< schedulable_base > &&next) |
| void | update_next (std::shared_ptr< schedulable_base > &&next) |
Protected Member Functions | |
| template<typename NowStrategy> | |
| auto | get_advanced_call_handler () const |