ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
debounce_disposable (Observer &&in_observer, Worker &&in_worker, rpp::schedulers::duration period) | |
template<typename TT > | |
void | emplace_safe (TT &&v) |
std::optional< T > | extract_value () |
rpp::utils::pointer_under_lock< Observer > | get_observer_under_lock () |
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 Member Functions inherited from rpp::details::enable_wrapper_from_this< debounce_disposable< Observer, Worker, Container > > | |
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::composite_disposable_impl< Container > | |
virtual void | composite_dispose_impl (interface_disposable::Mode) noexcept |
Protected Member Functions inherited from rpp::interface_disposable | |
Protected Member Functions inherited from rpp::details::enable_wrapper_from_this< debounce_disposable< Observer, Worker, Container > > | |
void | set_weak_self (std::weak_ptr< interface_disposable > weak) |