Function main

examples/server_theme/on_transfer.cpp:91–130

}

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

  exec::static_thread_pool io_pool{1};
  ex::scheduler auto       io_sched = io_pool.get_scheduler();

  std::array<std::byte, 16 * 1024> buffer;

  exec::async_scope scope;

  // Fake a couple of requests
  for (int i = 0; i < 10; i++)
  {
    int  sock = i;
    auto buf  = reinterpret_cast<char*>(&buffer[0]);

    // A sender that just calls the legacy read function
    auto snd_read = ex::just(sock, buf, buffer.size()) | ex::then(legacy_read_from_socket);
    // The entire flow
    auto snd =
      // start by reading data on the I/O thread
      ex::starts_on(io_sched, std::move(snd_read))
      // do the processing on the worker threads pool
      | ex::continues_on(work_sched)
      // process the incoming data (on worker threads)
      | ex::then([buf](size_t read_len) { process_read_data(buf, read_len); })
      // done
      ;

    // execute the whole flow asynchronously
    scope.spawn(std::move(snd));
  }

  (void) stdexec::sync_wait(scope.on_empty());

  return 0;
}