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

Method on_next

src/rpp/rpp/operators/first.hpp:28–32  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

26
27 template<typename T>
28 void on_next(T&& v) const
29 {
30 observer.on_next(std::forward<T>(v));
31 observer.on_completed();
32 }
33
34 void on_completed() const
35 {

Callers

nothing calls this directly

Calls 1

on_completedMethod · 0.45

Tested by

no test coverage detected