ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp::subjects::details::subject_state< Type, Serialized > Class Template Reference

Public Types

using optimal_disposables_strategy = rpp::details::observables::fixed_disposables_strategy<1>
 

Public Member Functions

template<rpp::constraint::observer_of_type< Type > TObs>
void on_subscribe (TObs &&observer)
 
void on_next (const Type &v)
 
void on_error (const std::exception_ptr &err)
 
void on_completed ()
 
- Public Member Functions inherited from rpp::composite_disposable_impl< rpp::details::disposables::default_disposables_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
 
disposable_wrapper add (Fn &&invocable)
 
void remove (const disposable_wrapper &disposable) override
 
void clear () override
 
- 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< subject_state< Type, Serialized > >
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< rpp::details::disposables::default_disposables_container >
- Protected Member Functions inherited from rpp::interface_disposable
- Protected Member Functions inherited from rpp::details::enable_wrapper_from_this< subject_state< Type, Serialized > >
void set_weak_self (std::weak_ptr< interface_disposable > weak)
 

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