Function reader

example/streaming-server.cpp:159–175

This function will read one requests from the client at a time. Note that gRPC only allows calling agrpc::read after a previous read has completed.

// This function will read one requests from the client at a time. Note that gRPC only allows calling agrpc::read after
// a previous read has completed.
asio::awaitable<void> reader(BidiStreamingRPC& rpc, Channel& channel)
{
    while (true)
    {
        example::v1::Request request;
        if (!co_await rpc.read(request))
        {
            // Client is done writing.
            break;
        }
        // Send request to writer. The `max_buffer_size` of the channel acts as backpressure.
        (void)co_await channel.async_send(boost::system::error_code{}, std::move(request),
                                          asio::as_tuple(asio::use_awaitable));
    }
    // Signal the writer to complete.
    channel.close();
}

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