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++.
Public Types | Public Member Functions | Static Public Member Functions | List of all members
rxcpp::composite_subscription Class Reference

controls lifetime for scheduler::schedule and observable<T, SourceOperator>::subscribe. More...

#include <rx-subscription.hpp>

Inheritance diagram for rxcpp::composite_subscription:
Inheritance graph
[legend]
Collaboration diagram for rxcpp::composite_subscription:
Collaboration graph
[legend]

Public Types

typedef subscription::weak_state_type weak_subscription
 
- Public Types inherited from rxcpp::subscription
typedef std::weak_ptr< base_subscription_state > weak_state_type
 
- Public Types inherited from rxcpp::subscription_base
typedef tag_subscription subscription_tag
 

Public Member Functions

 composite_subscription (detail::tag_composite_subscription_empty et)
 
 composite_subscription ()
 
 composite_subscription (const composite_subscription &o)
 
 composite_subscription (composite_subscription &&o)
 
composite_subscriptionoperator= (composite_subscription o)
 
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
 
bool is_subscribed () const
 
void unsubscribe () const
 
- Public Member Functions inherited from rxcpp::subscription
 subscription ()
 
template<class U >
 subscription (U u, typename std::enable_if<!is_subscription< U >::value, void **>::type=nullptr)
 
template<class U >
 subscription (U u, typename std::enable_if<!std::is_same< subscription, U >::value &&is_subscription< U >::value, void **>::type=nullptr)
 
 subscription (const subscription &o)
 
 subscription (subscription &&o)
 
subscriptionoperator= (subscription o)
 
bool is_subscribed () const
 
void unsubscribe () const
 
weak_state_type get_weak ()
 

Static Public Member Functions

static composite_subscription empty ()
 
- Static Public Member Functions inherited from rxcpp::subscription
static subscription lock (weak_state_type w)
 
static rxu::maybe< subscriptionmaybe_lock (weak_state_type w)
 

Additional Inherited Members

- Protected Attributes inherited from rxcpp::subscription
std::shared_ptr< base_subscription_state > state
 

Detailed Description

controls lifetime for scheduler::schedule and observable<T, SourceOperator>::subscribe.

Member Typedef Documentation

◆ weak_subscription

Constructor & Destructor Documentation

◆ composite_subscription() [1/4]

rxcpp::composite_subscription::composite_subscription ( detail::tag_composite_subscription_empty  et)
inline

◆ composite_subscription() [2/4]

rxcpp::composite_subscription::composite_subscription ( )
inline

◆ composite_subscription() [3/4]

rxcpp::composite_subscription::composite_subscription ( const composite_subscription o)
inline

◆ composite_subscription() [4/4]

rxcpp::composite_subscription::composite_subscription ( composite_subscription &&  o)
inline

Member Function Documentation

◆ add() [1/2]

weak_subscription rxcpp::composite_subscription::add ( subscription  s) const
inline

◆ add() [2/2]

template<class F >
auto rxcpp::composite_subscription::add ( f) const -> typename std::enable_if<detail::is_unsubscribe_function<F>::value, weak_subscription>::type
inline

◆ empty()

static composite_subscription rxcpp::composite_subscription::empty ( )
inlinestatic

◆ is_subscribed()

bool rxcpp::subscription::is_subscribed
inline

◆ operator=()

composite_subscription& rxcpp::composite_subscription::operator= ( composite_subscription  o)
inline

◆ remove()

void rxcpp::composite_subscription::remove ( weak_subscription  w) const
inline

◆ unsubscribe()

void rxcpp::subscription::unsubscribe
inline

The documentation for this class was generated from the following file: