| 142 | } |
| 143 | |
| 144 | void StreamingSourceManager::stopAllAndWait(const QString& reason) { |
| 145 | std::vector<DatasetId> dataset_ids; |
| 146 | dataset_ids.reserve(sessions_.size()); |
| 147 | for (const auto& [dataset_id, _sess] : sessions_) { |
| 148 | dataset_ids.push_back(dataset_id); |
| 149 | } |
| 150 | for (const DatasetId dataset_id : dataset_ids) { |
| 151 | stopDatasetAndWait(dataset_id, reason); |
| 152 | } |
| 153 | } |
| 154 | |
| 155 | void StreamingSourceManager::onSourceChanged(const QString& plugin_id) { |
| 156 | selected_plugin_ = plugin_id; |
no test coverage detected