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

Method on_completed

src/rpp/rpp/observers/observer.hpp:135–144  ·  view source on GitHub ↗

* @brief Observable calls this method to notify observer about completion of emissions. * @invariant Obtaining of this call means no any further on_next/on_error or on_completed calls from this Observable */

Source from the content-addressed store, hash-verified

133 * @invariant Obtaining of this call means no any further on_next/on_error or on_completed calls from this Observable
134 */
135 void on_completed() const noexcept
136 {
137 if (!is_disposed())
138 {
139 rpp::utils::finally_action finally{[&] {
140 m_disposable.dispose();
141 }};
142 m_strategy.on_completed();
143 }
144 }
145
146 private:
147 RPP_NO_UNIQUE_ADDRESS Strategy m_strategy;

Callers

nothing calls this directly

Calls 1

disposeMethod · 0.45

Tested by

no test coverage detected