|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
| template<rpp::constraint::decayed_same_as< TData > T> | |
| void | on_next (T &&message) const |
| void | on_error (const std::exception_ptr &) const |
| void | on_completed () const |
Static Public Member Functions | |
| static constexpr bool | is_disposed () |
| static constexpr void | set_upstream (const rpp::disposable_wrapper &) |
Public Attributes | |
| std::reference_wrapper< base_writer > | owner {} |
Static Public Attributes | |
| static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::Auto |