Searched refs:selectedSinkInner (Results 1 – 7 of 7) sorted by relevance
161 auto selectedSinkInner = on_exception( in on_subscribe() local164 if (selectedSinkInner.empty()) { in on_subscribe()167 selectedSource->subscribe(std::move(selectedSinkInner.get())); in on_subscribe()
169 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe() local171 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
201 auto selectedSinkInner = on_exception( in on_subscribe() local204 if (selectedSinkInner.empty()) { in on_subscribe()207 selectedSource->subscribe(std::move(selectedSinkInner.get())); in on_subscribe()
187 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe() local188 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
195 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe() local196 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
191 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe() local192 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()
212 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe() local213 selectedSource.subscribe(std::move(selectedSinkInner)); in on_subscribe()