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-connectable_observable.hpp>
Public Types | |
typedef tag_dynamic_observable | dynamic_observable_tag |
Public Types inherited from rxcpp::dynamic_observable< T > | |
typedef tag_dynamic_observable | dynamic_observable_tag |
Public Types inherited from rxcpp::sources::source_base< T > | |
typedef T | value_type |
typedef tag_source | source_tag |
Public Member Functions | |
dynamic_connectable_observable () | |
template<class SOF > | |
dynamic_connectable_observable (SOF sof) | |
template<class SF , class CF > | |
dynamic_connectable_observable (SF &&sf, CF &&cf) | |
void | on_connect (composite_subscription cs) const |
Public Member Functions inherited from rxcpp::dynamic_observable< T > | |
dynamic_observable () | |
template<class SOF > | |
dynamic_observable (SOF &&sof, typename std::enable_if<!is_dynamic_observable< SOF >::value, void ** >::type=0) | |
void | on_subscribe (subscriber< T > o) const |
template<class Subscriber > | |
std::enable_if< is_subscriber< Subscriber >::value, void >::type | on_subscribe (Subscriber o) const |
typedef tag_dynamic_observable rxcpp::dynamic_connectable_observable< T >::dynamic_observable_tag |
|
inline |
|
inlineexplicit |
|
inline |
|
inline |