Function start

demo_example/async_echo_client.cpp:23–57

using asio::ip::tcp;

async_simple::coro::Lazy<void> start(asio::io_context &io_context,
                                     std::string host, std::string port) {
    asio::ip::tcp::socket socket(io_context);
    auto ec = co_await async_connect(io_context, socket, host, port);
    if (ec) {
        std::cout << "Connect error: " << ec.message() << '\n';
        throw asio::system_error(ec);
    }
    std::cout << "Connect to " << host << ":" << port << " successfully.\n";
    const int max_length = 1024;
    char write_buf[max_length] = {"hello async_simple"};
    char read_buf[max_length];
    const int count = 100000;
    for (int i = 0; i < count; ++i) {
        co_await async_write(socket, asio::buffer(write_buf, max_length));
        auto [error, reply_length] = co_await async_read_some(
            socket, asio::buffer(read_buf, max_length));
        if (error == asio::error::eof) {
            std::cout << "eof at message index: " << i << '\n';
            break;
        } else if (error) {
            std::cout << "error: " << error.message()
                      << ", message index: " << i << '\n';
            throw asio::system_error(error);
        }

        // handle read data as your wish.
    }

    std::cout << "Finished send and receive " << count
              << " messages, client will close.\n";
    std::error_code ignore_ec;
    socket.shutdown(asio::ip::tcp::socket::shutdown_both, ignore_ec);
    io_context.stop();
}

int main(int argc, char *argv[]) {
    try {