|
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++.
|
Classes | |
| class | action |
| action provides type-forgetting for a potentially recursive set of calls to a function that takes a schedulable More... | |
| struct | action_base |
| struct | current_thread |
| struct | event_loop |
| struct | immediate |
| struct | new_thread |
| class | recurse |
| class | recursed |
| class | recursion |
| recursion is used by the scheduler to signal to each action whether tail recursion is allowed. More... | |
| class | run_loop |
| struct | run_loop_scheduler |
| struct | same_worker |
| class | schedulable |
| struct | schedulable_base |
| class | scheduler |
| allows functions to be called at specified times and possibly in other contexts. More... | |
| struct | scheduler_base |
| class | scheduler_interface |
| class | test |
| struct | virtual_time |
| class | weak_worker |
| class | worker |
| struct | worker_base |
| class | worker_interface |
Typedefs | |
| typedef std::function< std::thread(std::function< void()>)> | thread_factory |
Functions | |
| bool | operator== (const worker &lhs, const worker &rhs) |
| bool | operator!= (const worker &lhs, const worker &rhs) |
| template<class Scheduler , class... ArgN> | |
| scheduler | make_scheduler (ArgN &&...an) |
| scheduler | make_scheduler (std::shared_ptr< scheduler_interface > si) |
| action | make_action_empty () |
| template<class F > | |
| action | make_action (F &&f) |
| auto | make_schedulable (const schedulable &scbl) -> schedulable |
| auto | make_schedulable (schedulable &&scbl) -> schedulable |
| schedulable | make_schedulable (worker sc, action a) |
| schedulable | make_schedulable (worker sc, composite_subscription cs, action a) |
| template<class F > | |
| auto | make_schedulable (worker sc, F &&f) -> typename std::enable_if< detail::is_action_function< F >::value, schedulable >::type |
| template<class F > | |
| auto | make_schedulable (worker sc, composite_subscription cs, F &&f) -> typename std::enable_if< detail::is_action_function< F >::value, schedulable >::type |
| template<class F > | |
| auto | make_schedulable (schedulable scbl, composite_subscription cs, F &&f) -> typename std::enable_if< detail::is_action_function< F >::value, schedulable >::type |
| template<class F > | |
| auto | make_schedulable (schedulable scbl, worker sc, F &&f) -> typename std::enable_if< detail::is_action_function< F >::value, schedulable >::type |
| template<class F > | |
| auto | make_schedulable (schedulable scbl, F &&f) -> typename std::enable_if< detail::is_action_function< F >::value, schedulable >::type |
| auto | make_schedulable (schedulable scbl, composite_subscription cs) -> schedulable |
| auto | make_schedulable (schedulable scbl, worker sc, composite_subscription cs) -> schedulable |
| auto | make_schedulable (schedulable scbl, worker sc) -> schedulable |
| const scheduler & | make_current_thread () |
| scheduler | make_event_loop () |
| scheduler | make_event_loop (thread_factory tf) |
| const scheduler & | make_immediate () |
| scheduler | make_new_thread () |
| scheduler | make_new_thread (thread_factory tf) |
| scheduler | make_run_loop (const run_loop &r) |
| scheduler | make_same_worker (rxsc::worker w) |
| test | make_test () |
| typedef std::function<std::thread(std::function<void()>)> rxcpp::schedulers::thread_factory |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
| auto rxcpp::schedulers::make_schedulable | ( | worker | sc, |
| F && | f | ||
| ) | -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type |
| auto rxcpp::schedulers::make_schedulable | ( | worker | sc, |
| composite_subscription | cs, | ||
| F && | f | ||
| ) | -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type |
| auto rxcpp::schedulers::make_schedulable | ( | schedulable | scbl, |
| composite_subscription | cs, | ||
| F && | f | ||
| ) | -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type |
| auto rxcpp::schedulers::make_schedulable | ( | schedulable | scbl, |
| worker | sc, | ||
| F && | f | ||
| ) | -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type |
| auto rxcpp::schedulers::make_schedulable | ( | schedulable | scbl, |
| F && | f | ||
| ) | -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
1.8.11