Method loop

example/http/server/stackless/http_server_stackless.cpp:252–311

    #include <boost/asio/yield.hpp>

    void
    loop(beast::error_code ec, std::size_t bytes_transferred)
    {
        boost::ignore_unused(bytes_transferred);
        reenter(*this)
        {
            for(;;)
            {
                // Make the request empty before reading,
                // otherwise the operation behavior is undefined.
                req_ = {};

                // Set the timeout.
                stream_.expires_after(std::chrono::seconds(30));

                // Read a request
                yield http::async_read(stream_, buffer_, req_,
                    beast::bind_front_handler(
                        &session::loop,
                        shared_from_this()));

                if(ec == http::error::end_of_stream)
                {
                    // The remote host closed the connection
                    break;
                }
                if(ec)
                    return fail(ec, "read");

                yield {
                    // Handle request
                    http::message_generator msg =
                        handle_request(*doc_root_, std::move(req_));

                    // Determine if we should close the connection
                    keep_alive_ = msg.keep_alive();

                    // Send the response
                    beast::async_write(
                        stream_,
                        std::move(msg),
                        beast::bind_front_handler(
                            &session::loop, shared_from_this()));
                }

                if(ec)
                    return fail(ec, "write");
                if(! keep_alive_)
                {
                    // This means we should close the connection, usually because
                    // the response indicated the "Connection: close" semantic.
                    break;
                }
            }

            // Send a TCP shutdown
            stream_.socket().shutdown(tcp::socket::shutdown_send, ec);