ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::details::subscriber_base Class Reference

base implementation of subscriber with possibility to obtain observer's callbacks, query subscription state, unsubscribe and etc. Each observer's callback checks for actual subscription More...

#include <subscriber_base.hpp>

Inheritance diagram for rpp::details::subscriber_base:
rpp::specific_subscriber< T, dynamic_observer< T > > rpp::specific_subscriber< Type, Observer > rpp::dynamic_subscriber< T >

Public Member Functions

 subscriber_base (composite_subscription &&subscription=composite_subscription{})
 
 subscriber_base (const composite_subscription &subscription)
 
const composite_subscriptionget_subscription () const
 
bool is_subscribed () const
 
void unsubscribe () const
 

Protected Member Functions

void do_if_subscribed_and_unsubscribe (const auto &callable) const
 

Detailed Description

base implementation of subscriber with possibility to obtain observer's callbacks, query subscription state, unsubscribe and etc. Each observer's callback checks for actual subscription

Template Parameters
Typetype of values expected by this subscriber

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