Searched refs:selectedSinkSource (Results 1 – 1 of 1) sorted by relevance
194 auto selectedSinkSource = on_exception( in on_subscribe() local197 if (selectedSinkSource.empty()) { in on_subscribe()200 source->subscribe(std::move(selectedSinkSource.get())); in on_subscribe()