Home
last modified time | relevance | path

Searched refs:selectedResult (Results 1 – 5 of 5) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-combine_latest.hpp171 auto selectedResult = rxu::apply(values, state->selector); in subscribe_one() local
172 state->out.on_next(selectedResult); in subscribe_one()
Drx-with_latest_from.hpp171 auto selectedResult = rxu::apply(values, state->selector); in subscribe_one() local
172 state->out.on_next(selectedResult); in subscribe_one()
Drx-zip.hpp198 … auto selectedResult = rxu::apply_to_each(state->pending, extract_value_front(), state->selector); in subscribe_one() local
199 state->out.on_next(selectedResult); in subscribe_one()
Drx-flat_map.hpp197 auto selectedResult = state->selectResult(st, std::move(ct)); in on_subscribe() local
198 state->out.on_next(std::move(selectedResult)); in on_subscribe()
Drx-concat_map.hpp182 auto selectedResult = state->selectResult(st, std::move(ct)); in on_subscribe() local
183 state->out.on_next(std::move(selectedResult)); in on_subscribe()