#include <rx-scheduler.hpp>
◆ clock_type
◆ weak_subscription
◆ ~schedulable()
rxcpp::schedulers::schedulable::~schedulable |
( |
| ) |
|
|
inline |
◆ schedulable() [1/4]
rxcpp::schedulers::schedulable::schedulable |
( |
| ) |
|
|
inline |
◆ schedulable() [2/4]
rxcpp::schedulers::schedulable::schedulable |
( |
worker |
q, |
|
|
action |
a |
|
) |
| |
|
inline |
action and worker share lifetime
◆ schedulable() [3/4]
action and worker have independent lifetimes
◆ schedulable() [4/4]
◆ add() [1/2]
◆ add() [2/2]
template<class F >
auto rxcpp::schedulers::schedulable::add |
( |
F |
f | ) |
const -> typename std::enable_if<rxcpp::detail::is_unsubscribe_function<F>::value, weak_subscription>::type |
|
inline |
◆ clear()
void rxcpp::schedulers::schedulable::clear |
( |
| ) |
const |
|
inline |
◆ empty()
◆ get_action() [1/2]
const action& rxcpp::schedulers::schedulable::get_action |
( |
| ) |
const |
|
inline |
◆ get_action() [2/2]
action& rxcpp::schedulers::schedulable::get_action |
( |
| ) |
|
|
inline |
◆ get_subscription() [1/2]
◆ get_subscription() [2/2]
◆ get_worker() [1/2]
const worker rxcpp::schedulers::schedulable::get_worker |
( |
| ) |
const |
|
inline |
◆ get_worker() [2/2]
worker rxcpp::schedulers::schedulable::get_worker |
( |
| ) |
|
|
inline |
◆ is_recursed()
bool rxcpp::schedulers::schedulable::is_recursed |
( |
| ) |
const |
|
inline |
◆ is_subscribed()
bool rxcpp::schedulers::schedulable::is_subscribed |
( |
| ) |
const |
|
inline |
◆ now()
clock_type::time_point rxcpp::schedulers::schedulable::now |
( |
| ) |
const |
|
inline |
◆ operator()() [1/2]
void rxcpp::schedulers::schedulable::operator() |
( |
| ) |
const |
|
inline |
requests tail-recursion of the same action this will exit the process if called when is_recursed() is false. Note: to improve perf it is not required to call is_recursed() before calling this operator. Context is sufficient. The schedulable passed to the action by the scheduler will return true from is_recursed()
◆ operator()() [2/2]
void rxcpp::schedulers::schedulable::operator() |
( |
const recurse & |
r | ) |
const |
|
inline |
◆ remove()
◆ schedule() [1/3]
void rxcpp::schedulers::schedulable::schedule |
( |
| ) |
const |
|
inline |
put this on the queue of the stored scheduler to run asap
◆ schedule() [2/3]
void rxcpp::schedulers::schedulable::schedule |
( |
clock_type::time_point |
when | ) |
const |
|
inline |
put this on the queue of the stored scheduler to run at the specified time
◆ schedule() [3/3]
void rxcpp::schedulers::schedulable::schedule |
( |
clock_type::duration |
when | ) |
const |
|
inline |
put this on the queue of the stored scheduler to run after a delay from now
◆ set_recursed()
auto rxcpp::schedulers::schedulable::set_recursed |
( |
const recurse & |
r | ) |
const -> decltype(recursed_scope.reset(r)) |
|
inline |
◆ unsubscribe()
void rxcpp::schedulers::schedulable::unsubscribe |
( |
| ) |
const |
|
inline |
The documentation for this class was generated from the following file: