Searched refs:selectedResult (Results 1 – 5 of 5) sorted by relevance
171 auto selectedResult = rxu::apply(values, state->selector); in subscribe_one() local172 state->out.on_next(selectedResult); in subscribe_one()
198 … auto selectedResult = rxu::apply_to_each(state->pending, extract_value_front(), state->selector); in subscribe_one() local199 state->out.on_next(selectedResult); in subscribe_one()
197 auto selectedResult = state->selectResult(st, std::move(ct)); in on_subscribe() local198 state->out.on_next(std::move(selectedResult)); in on_subscribe()
182 auto selectedResult = state->selectResult(st, std::move(ct)); in on_subscribe() local183 state->out.on_next(std::move(selectedResult)); in on_subscribe()