subscriber which uses dynamic_observer<T> to hide original callbacks More...
#include <dynamic_subscriber.hpp>
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_subscription & | get_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 |
subscriber which uses dynamic_observer<T> to hide original callbacks
T | type of values expected by this subscriber |