ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::dynamic_subscriber< T > Class Template Referencefinal

subscriber which uses dynamic_observer<T> to hide original callbacks More...

#include <dynamic_subscriber.hpp>

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

Public Member Functions

template<constraint::subscriber_of_type< T > TSub>
requires (!std::is_same_v<std::decay_t<TSub>, dynamic_subscriber<T>>)
 dynamic_subscriber (const TSub &subscriber)
 
- Public Member Functions inherited from rpp::specific_subscriber< T, dynamic_observer< T > >
 specific_subscriber (Types &&...vals)
 
 specific_subscriber (composite_subscription sub, Types &&...vals)
 
const Observer & get_observer () const
 
void on_next (const Type &val) const
 
void on_next (Type &&val) const
 
void on_error (const std::exception_ptr &err) const
 
void on_completed () const
 
auto as_dynamic () const &
 
auto as_dynamic () &&
 
- Public Member Functions inherited from rpp::details::subscriber_base
 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
 

Additional Inherited Members

- Protected Member Functions inherited from rpp::details::subscriber_base
void do_if_subscribed_and_unsubscribe (const auto &callable) const
 

Detailed Description

template<constraint::decayed_type T>
class rpp::dynamic_subscriber< T >

subscriber which uses dynamic_observer<T> to hide original callbacks

Template Parameters
Ttype of values expected by this subscriber
Examples
create.cpp, and switch_map.cpp.

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