MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / on_error

Method on_error

src/rpp/rpp/observers/observer.hpp:120–129  ·  view source on GitHub ↗

* @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 */

Source from the content-addressed store, hash-verified

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.

Callers

nothing calls this directly

Calls 1

disposeMethod · 0.45

Tested by

no test coverage detected