ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp::operators::details::merge_observer_strategy< TObserver > Class Template Referencefinal

Public Member Functions

 merge_observer_strategy (TObserver &&observer)
 
template<typename T >
void on_next (T &&v) const
 
- Public Member Functions inherited from rpp::operators::details::merge_observer_base_strategy< TObserver >
 merge_observer_base_strategy (std::shared_ptr< merge_disposable< TObserver > > &&disposable)
 
 merge_observer_base_strategy (const std::shared_ptr< merge_disposable< TObserver > > &disposable)
 
void set_upstream (const rpp::disposable_wrapper &d) const
 
bool is_disposed () const
 
void on_error (const std::exception_ptr &err) const
 
void on_completed () const
 

Additional Inherited Members

- Static Public Attributes inherited from rpp::operators::details::merge_observer_base_strategy< TObserver >
static constexpr auto preferred_disposables_mode = rpp::details::observers::disposables_mode::None
 
- Protected Attributes inherited from rpp::operators::details::merge_observer_base_strategy< TObserver >
std::shared_ptr< merge_disposable< TObserver > > m_disposable
 
std::vector< rpp::disposable_wrapperm_disposables {}
 

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