|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
| template<typename T> | |
| void | on_next (T &&v) const |
| void | on_completed () const |
| void | on_error (const std::exception_ptr &err) const |
| void | set_upstream (const disposable_wrapper &d) |
| bool | is_disposed () const |
Public Attributes | |
| RPP_NO_UNIQUE_ADDRESS TObserver | observer |
| std::optional< Type > | value {} |
Static Public Attributes | |
| static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::None |