Method noMoreSources

bolt/exec/ExchangeQueue.cpp:66–74

}

void ExchangeQueue::noMoreSources() {
  std::vector<ContinuePromise> promises;
  {
    std::lock_guard<std::mutex> l(mutex_);
    noMoreSources_ = true;
    promises = checkCompleteLocked();
  }
  clearPromises(promises);
}

void ExchangeQueue::close() {
  std::vector<ContinuePromise> promises;