|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
|
template<rpp::constraint::observer_strategy< Type > Strategy> requires (!rpp::constraint::decayed_same_as<Strategy, dynamic_strategy<Type>>) | |
| dynamic_strategy (observer< Type, Strategy > &&obs) | |
| void | set_upstream (const disposable_wrapper &d) noexcept |
| bool | is_disposed () const noexcept |
| void | on_next (const Type &v) const noexcept |
| void | on_next (Type &&v) const noexcept |
| void | on_error (const std::exception_ptr &err) const noexcept |
| void | on_completed () const noexcept |
Static Public Attributes | |
| static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::None |