rpp::operators::details::delay_disposable< Observer, Worker, Container > Struct Template Reference

Public Types
using	T = rpp::utils::extract_observer_type_t<Observer>

Public Member Functions
	delay_disposable (Observer &&in_observer, Worker &&in_worker, rpp::schedulers::duration delay)
Public Member Functions inherited from rpp::composite_disposable_impl< Container >
	composite_disposable_impl (const composite_disposable_impl &)=delete
	composite_disposable_impl (composite_disposable_impl &&other) noexcept=delete
bool	is_disposed () const noexcept final
	Check if this disposable is just disposed.
void	dispose_impl (interface_disposable::Mode mode) noexcept final
void	add (disposable_wrapper disposable) override
void	remove (const disposable_wrapper &disposable) override
void	clear () override
template<rpp::constraint::is_nothrow_invocable Fn>
disposable_wrapper	add (Fn &&invocable)
Public Member Functions inherited from rpp::interface_composite_disposable
template<rpp::constraint::is_nothrow_invocable Fn>
disposable_wrapper	add (Fn &&invocable)
Public Member Functions inherited from rpp::interface_disposable
void	dispose () noexcept
	Dispose disposable and free any underlying resources and etc.

Public Attributes
RPP_NO_UNIQUE_ADDRESS Observer	observer
RPP_NO_UNIQUE_ADDRESS Worker	worker
rpp::schedulers::duration	delay
std::mutex	mutex {}
std::queue< emission< T > >	queue
bool	is_active {}

Additional Inherited Members
Protected Types inherited from rpp::interface_disposable
enum class	Mode : bool { Disposing = 0 , Destroying = 1 }
Protected Member Functions inherited from rpp::composite_disposable_impl< Container >
virtual void	composite_dispose_impl (interface_disposable::Mode) noexcept

---

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

• src/rpp/rpp/operators/delay.hpp