Method ~StreamingSourceManager

pj_app/src/StreamingSourceManager.cpp:97–110

}

StreamingSourceManager::~StreamingSourceManager() {
  // Cooperative stop + join for every live session. We can't go through
  // onWorkerFinished here because the UI event loop won't run again.
  for (auto& [dataset_id, sess] : sessions_) {
    if (sess->runtime_host != nullptr) {
      sess->runtime_host->requestStop("manager shutdown");
    }
  }
  for (auto& [dataset_id, sess] : sessions_) {
    if (sess->worker != nullptr) {
      sess->worker->wait();
    }
  }
}

bool StreamingSourceManager::hasActiveSession() const {
  return !sessions_.empty();