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

Method on_next

src/rpp/rpp/observers/observer.hpp:84–95  ·  view source on GitHub ↗

* @brief Observable calls this method to notify observer about new value. * * @note obtains value by const-reference to original object. */

Source from the content-addressed store, hash-verified

82 * @note obtains value by const-reference to original object.
83 */
84 void on_next(const Type& v) const noexcept
85 {
86 try
87 {
88 if (!is_disposed())
89 m_strategy.on_next(v);
90 }
91 catch (...)
92 {
93 on_error(std::current_exception());
94 }
95 }
96
97 /**
98 * @brief Observable calls this method to notify observer about new value.

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected