Method Run

generator/raw_generator_writer.cpp:21–37

}

void RawGeneratorWriter::Run()
{
  m_thread = std::thread([&]()
  {
    while (true)
    {
      FeatureProcessorChunk chunk;
      m_queue->WaitAndPop(chunk);
      // As a sign of the end of tasks, we use an empty message. We have the right to do that,
      // because there is only one reader.
      if (!chunk.has_value())
        return;

      Write(*chunk);
    }
  });
}

std::vector<std::string> RawGeneratorWriter::GetNames()
{