|
ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
| mock_observer_strategy (bool copy_values=true) | |
| void | on_next (const Type &v) const noexcept |
| void | on_next (Type &&v) const noexcept |
| void | on_error (const std::exception_ptr &) const noexcept |
| void | on_completed () const noexcept |
| size_t | get_total_on_next_count () const |
| size_t | get_on_next_const_ref_count () const |
| size_t | get_on_next_move_count () const |
| size_t | get_on_error_count () const |
| size_t | get_on_completed_count () const |
| std::vector< Type > | get_received_values () const |
| auto | get_observer () const |
| auto | get_observer (rpp::composite_disposable_wrapper d) const |
Static Public Member Functions | |
| static bool | is_disposed () noexcept |
| static void | set_upstream (const rpp::disposable_wrapper &) noexcept |
Static Public Attributes | |
| static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::Auto |