Method removeTask

bolt/exec/OutputBufferManager.cpp:160–175

}

void OutputBufferManager::removeTask(const std::string& taskId) {
  auto buffer =
      buffers_.withLock([&](auto& buffers) -> std::shared_ptr<OutputBuffer> {
        auto it = buffers.find(taskId);
        if (it == buffers.end()) {
          // Already removed.
          return nullptr;
        }
        auto taskBuffer = it->second;
        buffers.erase(taskId);
        return taskBuffer;
      });
  if (buffer != nullptr) {
    buffer->terminate();
  }
}

std::string OutputBufferManager::toString() {
  return buffers_.withLock([](const auto& buffers) {