pull()

size_t fl::Server::pull

(

)

Pull requests from source, process, queue responses.

Definition at line 47 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).
        // `noEnqueue` is the new envelope marker (#3228); accept legacy `__skip`
        // for one release of back-compat.
        bool isScheduledAck = response.contains("scheduled") && response["scheduled"].as_bool().value_or(false);
        bool isAsyncSkip = (response.contains("noEnqueue") && response["noEnqueue"].as_bool().value_or(false))
                       || (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 fl::FL_NO_EXCEPT, mOutgoingQueue, fl::adl_barrier::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: