Function main

examples/server_theme/split_bulk.cpp:185–238

}

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

  // Fake a couple of edge_detect requests
  for (int i = 0; i < 3; i++)
  {
    // Create a test request
    http_request req{.url_ = "/edge_detect", .headers_ = {}, .body_ = "scene"};

    // The handler for the /edge_detect requests
    ex::sender auto snd = handle_edge_detection_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)));
  }

  // Fake a couple of multi_blur requests
  for (int i = 0; i < 3; i++)
  {
    // Create a test request
    http_request req{.url_ = "/multi_blur", .headers_ = {}, .body_ = "img1\nimg2\nimg3\nimg4\n"};

    // The handler for the /edge_detect requests
    ex::sender auto snd = handle_multi_blur_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();
}