* @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
| 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 |
no outgoing calls
no test coverage detected