Function main

speech/api/streaming_transcribe_singlethread.cc:154–182

};

int main(int argc, char** argv) try {
  // Create a CompletionQueue to demux the I/O and other asynchronous
  // operations, and dedicate a thread to it.
  g::CompletionQueue cq;
  auto runner = std::thread{[](auto cq) { cq.Run(); }, cq};
  // Shutdown the completion queue and join the thread.
  std::shared_ptr<void> auto_shutdown(nullptr, [&](void*) {
    cq.Shutdown();
    runner.join();
  });

  // Create a Speech client with the default configuration.
  auto client = speech::SpeechClient(speech::MakeSpeechConnection(
      g::Options{}.set<g::GrpcCompletionQueueOption>(cq)));

  // Create a handler for the stream and run it until closed.
  auto handler = Handler::Create(cq, ParseArguments(argc, argv));
  auto status = handler->Start(client).get();

  if (!status.ok()) {
    std::cerr << "Error in transcribe stream: " << status << "\n";
    return 1;
  }
  return 0;
} catch (std::exception const& ex) {
  std::cerr << "Standard C++ exception thrown: " << ex.what() << "\n"
            << kUsage << "\n";
  return 1;
}