Function main

examples/server_theme/then_upon.cpp:188–228

}

auto main() -> int
{
  // Create a thread pool and get a scheduler from it
  exec::async_scope        scope;
  exec::static_thread_pool pool{8};
  ex::scheduler auto       sched = pool.get_scheduler();

  // Fake a couple of requests
  for (int i = 0; i < 12; i++)
  {
    // Create a test request
    char const * body = "";
    if (i % 2 == 0)
      body = "human";
    else if (i % 3 == 0)
      body = "cat";
    else if (i % 5 == 0)
      body = "dog";
    else if (i % 7 == 0)
      body = "bird";
    http_request req{.url_ = "/classify", .headers_ = {}, .body_ = body};

    // The handler for the "classify" requests
    ex::sender auto snd = handle_classify_request(req);

    // Pack this into a simplified flow and execute it asynchronously
    ex::sender auto action = std::move(snd)
                           | ex::then(
                               [](http_response resp)
                               {
                                 std::ostringstream oss;
                                 oss << "Sending response: " << resp.status_code_ << " / "
                                     << resp.body_ << "\n";
                                 std::cout << oss.str();
                               });
    scope.spawn(ex::starts_on(sched, std::move(action)));
  }

  stdexec::sync_wait(scope.on_empty());
  pool.request_stop();
}