Public Member Functions | |
template<typename ... TStates> requires (constraint::decayed_same_as<States, TStates> && ...) | |
dynamic_state_observer (std::invocable< T, States... > auto &&on_next, std::invocable< std::exception_ptr, States... > auto &&on_error, std::invocable< States... > auto &&on_completed, TStates &&... states) | |
dynamic_state_observer (std::shared_ptr< details::dynamic_observer_state_base< T > > state) | |
template<constraint::observer_of_type< T > TObserver> requires (!std::is_same_v<std::decay_t<TObserver>, dynamic_state_observer<T, States...>>) | |
dynamic_state_observer (TObserver &&obs) | |
Public Member Functions inherited from rpp::details::state_observer< T, utils::forwarding_on_next_for_pointer, utils::forwarding_on_error_for_pointer, utils::forwarding_on_completed_for_pointer, std::shared_ptr< dynamic_observer_state_base< T > > > | |
state_observer (std::invocable< T, States... > auto &&on_next, std::invocable< std::exception_ptr, States... > auto &&on_error, std::invocable< States... > auto &&on_completed, TStates &&...states) | |
void | on_next (const T &v) const |
Observable calls this methods to notify observer about new value. | |
void | on_next (T &&v) const |
Observable calls this methods to notify observer about new value. | |
void | on_error (const std::exception_ptr &err) const |
Observable calls this method to notify observer about some error during generation next data. | |
void | on_completed () const |
Observable calls this method to notify observer about finish of work. | |