Home
last modified time | relevance | path

Searched refs:selectedCollections (Results 1 – 2 of 2) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-concat.hpp151 if (!state->selectedCollections.empty()) { in on_subscribe()
152 auto value = state->selectedCollections.front(); in on_subscribe()
153 state->selectedCollections.pop_front(); in on_subscribe()
172 std::deque<collection_type> selectedCollections; in on_subscribe() member
204 state->selectedCollections.push_back(st); in on_subscribe()
205 } else if (state->selectedCollections.empty()) { in on_subscribe()
215 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()
Drx-concat_map.hpp191 if (!state->selectedCollections.empty()) { in on_subscribe()
192 auto value = state->selectedCollections.front(); in on_subscribe()
193 state->selectedCollections.pop_front(); in on_subscribe()
211 std::deque<source_value_type> selectedCollections; in on_subscribe() member
243 state->selectedCollections.push_back(st); in on_subscribe()
244 } else if (state->selectedCollections.empty()) { in on_subscribe()
254 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()