pull()

size_t fl::Server::pull

(

)

Pull requests from source, process, queue responses.

Definition at line 38 of file server.cpp.hpp.

                    {
    if (!mRequestSource || !mRequestHandler) {
        return 0;
    }
 
    size_t processed = 0;
 
    // Pull JSON-RPC requests from source until none available
    while (auto optRequest = mRequestSource()) {
        fl::json request = fl::move(*optRequest);
 
        // Process request through handler
        fl::json response = mRequestHandler(request);
 
        // Queue response (skip scheduled acknowledgments and async skip markers)
        bool isScheduledAck = response.contains("scheduled") && response["scheduled"].as_bool().value_or(false);
        bool isAsyncSkip = response.contains("__skip") && response["__skip"].as_bool().value_or(false);
        if (!response.is_null() && !isScheduledAck && !isAsyncSkip) {
            mOutgoingQueue.push_back(fl::move(response));
        }
 
        processed++;
    }
 
    return processed;
}

References mOutgoingQueue, fl::fl::move(), mRequestHandler, and mRequestSource.

Referenced by operator=(), fl::Remote::update(), and update().

Here is the call graph for this function:

Here is the caller graph for this function: