Function worker

example/thread.cpp:31–54

the worker wrapper

// the worker wrapper
cobalt::thread worker(request_channel & work)
{
  while (work.is_open())
  {
    auto [ec, a, b, respond_to] = co_await work.async_receive(boost::asio::as_tuple(cobalt::use_op));
    if (ec) // done, ignore. in our code this is only triggered by closing the channel
      break;

    // to emulate this being like awaiting on the same thread, we also deliver an exception.
    std::exception_ptr ep;
    int res = 0;
    try
    {
      res = co_await cpu_intense_work(a, b);
    }
    catch(...)
    {
      // this way exception get sent to the awaiting coro as if it was a call.
      ep = std::current_exception();
    }
    // send the response. If the channel is closed, the program will terminate!
    co_await respond_to->async_send(ep, res, boost::asio::redirect_error(cobalt::use_op, ec));
  }
}

cobalt::promise<void> work(request_channel & rc, int min_a, int max_a, int b)
{