rpp::operators::details::merge_observer_strategy< TObserver > Class Template Reference

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::Boolean
Protected Attributes inherited from rpp::operators::details::merge_observer_base_strategy< TObserver >
std::shared_ptr< merge_disposable< TObserver > >	m_disposable
std::vector< rpp::disposable_wrapper >	m_disposables {}

---

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

• src/rpp/rpp/operators/merge.hpp