* @brief Observable calls this method to notify observer about some error during generation next data. * @invariant Obtaining of this call means no any further on_next/on_error or on_completed calls from this Observable * @param err details of error */
| 118 | * @param err details of error |
| 119 | */ |
| 120 | void on_error(const std::exception_ptr& err) const noexcept |
| 121 | { |
| 122 | if (!is_disposed()) |
| 123 | { |
| 124 | rpp::utils::finally_action finally{[&] { |
| 125 | m_disposable.dispose(); |
| 126 | }}; |
| 127 | m_strategy.on_error(err); |
| 128 | } |
| 129 | } |
| 130 | |
| 131 | /** |
| 132 | * @brief Observable calls this method to notify observer about completion of emissions. |