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++.
|
#include <rx-observe_on.hpp>
Public Types | |
typedef coordinator< input_type > | coordinator_type |
Public Types inherited from rxcpp::coordination_base | |
typedef tag_coordination | coordination_tag |
Public Member Functions | |
observe_on_one_worker (rxsc::scheduler sc) | |
rxsc::scheduler::clock_type::time_point | now () const |
coordinator_type | create_coordinator (composite_subscription cs=composite_subscription()) const |
typedef coordinator<input_type> rxcpp::observe_on_one_worker::coordinator_type |
|
inlineexplicit |
|
inline |
|
inline |