Function writer

example/streaming-server.cpp:179–202

The writer will pick up reads from the reader through the channel and switch to the thread_pool to compute their response.

// The writer will pick up reads from the reader through the channel and switch to the thread_pool to compute their
// response.
asio::awaitable<bool> writer(BidiStreamingRPC& rpc, Channel& channel, asio::thread_pool& thread_pool)
{
    bool ok{true};
    while (ok)
    {
        const auto [ec, request] = co_await channel.async_receive(asio::as_tuple(asio::use_awaitable));
        if (ec)
        {
            // Channel got closed by the reader.
            break;
        }
        // In this example we switch to the thread_pool to compute the response.
        co_await asio::post(asio::bind_executor(thread_pool, asio::use_awaitable));

        // Compute the response.
        example::v1::Response response;
        response.set_integer(request.integer() * 2);

        // rpc.write() is thread-safe so we can interact with it from the thread_pool.
        ok = co_await rpc.write(response);
        // Now we are back on the main thread.
    }
    co_return ok;
}

auto bidirectional_streaming_rpc_handler(asio::thread_pool& thread_pool)
{