|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
| schedulables_queue (const schedulables_queue &)=delete | |
| schedulables_queue (schedulables_queue &&) noexcept=default | |
| schedulables_queue & | operator= (const schedulables_queue &other)=delete |
| schedulables_queue & | operator= (schedulables_queue &&other) noexcept=default |
| schedulables_queue (std::weak_ptr< shared_queue_data > shared_data) | |
| template<rpp::schedulers::constraint::schedulable_handler Handler, typename... Args, constraint::schedulable_fn< Handler, Args... > Fn> | |
| void | emplace (const time_point &timepoint, Fn &&fn, Handler &&handler, Args &&... args) |
| void | emplace (const time_point &timepoint, std::shared_ptr< schedulable_base > &&schedulable) |
| bool | is_empty () const |
| std::shared_ptr< schedulable_base > | pop () |
| const std::shared_ptr< schedulable_base > & | top () const |