specific version of subscriber which stores type of observer used inside to prevent extra allocations More...
#include <specific_subscriber.hpp>
Public Member Functions | |
template<typename ... Types> requires std::constructible_from<Observer, Types...> | |
specific_subscriber (Types &&...vals) | |
template<typename ... Types> requires std::constructible_from<Observer, Types...> | |
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 |
specific version of subscriber which stores type of observer used inside to prevent extra allocations
Type | type of values expected by this subscriber |
Observer | observer which was wrapped by this subscriber |