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