Public Member Functions
	concat_disposable (TObserver &&observer)
rpp::utils::pointer_under_lock< TObserver >	get_observer ()
rpp::utils::pointer_under_lock< std::queue< TObservable > >	get_queue ()
std::atomic< ConcatStage > &	stage ()
void	drain ()
void	handle_observable (const rpp::constraint::decayed_same_as< TObservable > auto &observable)
rpp::composite_disposable &	get_base_child_disposable ()
rpp::composite_disposable &	get_inner_child_disposable ()
Public Member Functions inherited from rpp::details::base_disposable_impl< interface_disposable >
	base_disposable_impl (const base_disposable_impl &)=delete
	base_disposable_impl (base_disposable_impl &&) noexcept=delete
bool	is_disposed () const noexcept final
Public Member Functions inherited from rpp::interface_disposable
void	dispose () noexcept
	Dispose disposable and free any underlying resources and etc.
Public Member Functions inherited from rpp::details::enable_wrapper_from_this< concat_disposable< TObservable, TObserver > >
disposable_wrapper_impl< TStrategy >	wrapper_from_this () const

Additional Inherited Members
Protected Types inherited from rpp::interface_disposable
enum class	Mode : bool { Disposing = 0 , Destroying = 1 }
Protected Member Functions inherited from rpp::details::enable_wrapper_from_this< concat_disposable< TObservable, TObserver > >
void	set_weak_self (std::weak_ptr< interface_disposable > weak)

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

Public Member Functions

Additional Inherited Members