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-subscription.hpp>
Public Types | |
typedef composite_subscription::weak_subscription | weak_subscription |
Public Types inherited from rxcpp::subscription_base | |
typedef tag_subscription | subscription_tag |
Public Member Functions | |
resource () | |
resource (T t, composite_subscription cs=composite_subscription()) | |
T & | get () |
composite_subscription & | get_subscription () |
bool | is_subscribed () const |
weak_subscription | add (subscription s) const |
template<class F > | |
auto | add (F f) const -> typename std::enable_if< detail::is_unsubscribe_function< F >::value, weak_subscription >::type |
void | remove (weak_subscription w) const |
void | clear () const |
void | unsubscribe () const |
Protected Attributes | |
composite_subscription | lifetime |
std::shared_ptr< rxu::detail::maybe< T > > | value |
typedef composite_subscription::weak_subscription rxcpp::resource< T >::weak_subscription |
|
inline |
|
inlineexplicit |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
protected |
|
protected |