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

Function first

src/rpp/rpp/operators/first.hpp:91–94  ·  view source on GitHub ↗

* @brief Emit only the first item. * * @marble first { source observable : +--1--2--3--| operator "first" : +--1| } * * @details Actually this operator is `take(1)` with exception during `on_completed` if no any emision happens. So, it just forwards first obtained emission and emits on_completed immediately * @throws rpp::ut

Source from the content-addressed store, hash-verified

89 * @see https://reactivex.io/documentation/operators/first.html
90 */
91 inline auto first()
92 {
93 return details::first_t{};
94 }
95} // namespace rpp::operators

Callers 3

test_first.cppFile · 0.85
mainFunction · 0.85
mainFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected