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 |