ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
void | set_upstream (const rpp::disposable_wrapper &d) const |
bool | is_disposed () const |
void | on_error (const std::exception_ptr &err) const |
void | on_completed () const |
Public Attributes | |
std::shared_ptr< TDisposable > | disposable {} |
Static Public Attributes | |
static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::Auto |