ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::details::dynamic_state_observer< T, States > Class Template Reference
Inheritance diagram for rpp::details::dynamic_state_observer< T, States >:
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 > > > rpp::details::typed_observer_tag< T > rpp::details::observer_tag

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.
 

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