Searched refs:selectedSource (Results 1 – 7 of 7) sorted by relevance
129 auto selectedSource = on_exception( in on_subscribe() local132 if (selectedSource.empty()) { in on_subscribe()167 selectedSource->subscribe(std::move(selectedSinkInner.get())); in on_subscribe()
146 auto selectedSource = state->coordinator.in(st); in on_subscribe() local171 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
168 auto selectedSource = on_exception( in on_subscribe() local171 if (selectedSource.empty()) { in on_subscribe()207 selectedSource->subscribe(std::move(selectedSinkInner.get())); in on_subscribe()
163 auto selectedSource = state->coordinator.in(st); in on_subscribe() local188 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
164 auto selectedSource = state->coordinator.in(st); in on_subscribe() local196 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
157 auto selectedSource = state->coordinator.in(st); in on_subscribe() local192 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
187 auto selectedSource = state->coordinator.in(selectedCollection); in on_subscribe() local213 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()