ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
void | set_upstream (const rpp::disposable_wrapper &d) const |
bool | is_disposed () const |
template<typename T > | |
void | on_next (T &&v) const |
void | on_error (const std::exception_ptr &err) const noexcept |
void | on_completed () const noexcept |
Public Attributes | |
std::shared_ptr< delay_disposable< Observer, Worker, Container > > | disposable {} |
Static Public Attributes | |
static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::None |