RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
|
allows functions to be called at specified times and possibly in other contexts. More...
#include <rx-scheduler.hpp>
Public Types | |
typedef scheduler_base::clock_type | clock_type |
Public Types inherited from rxcpp::schedulers::scheduler_base | |
typedef std::chrono::steady_clock | clock_type |
typedef tag_scheduler | scheduler_tag |
Public Member Functions | |
scheduler () | |
scheduler (detail::scheduler_interface_ptr i) | |
scheduler (detail::const_scheduler_interface_ptr i) | |
clock_type::time_point | now () const |
return the current time for this scheduler More... | |
worker | create_worker (composite_subscription cs=composite_subscription()) const |
Friends | |
bool | operator== (const scheduler &, const scheduler &) |
allows functions to be called at specified times and possibly in other contexts.
|
inline |
|
inlineexplicit |
|
inlineexplicit |
|
inline |
create a worker with a lifetime. when the worker is unsubscribed all scheduled items will be unsubscribed. items scheduled to a worker will be run one at a time. scheduling order is preserved: when more than one item is scheduled for time T then at time T they will be run in the order that they were scheduled.
|
inline |
return the current time for this scheduler