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

Method on_next

src/rpp/rpp/operators/tap.hpp:35–39  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

33
34 template<typename T>
35 void on_next(T&& v) const
36 {
37 onNext(utils::as_const(v));
38 observer.on_next(std::forward<T>(v));
39 }
40
41 void on_error(const std::exception_ptr& err) const
42 {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected