bindAsync()

void fl::Rpc::bindAsync	(	const char *	name,
		fl::function< void(ResponseSend &, const json &)>	fn,
		fl::RpcMode	mode = fl::RpcMode::ASYNC )

Bind async method with ResponseSend& parameter (for ASYNC/ASYNC_STREAM modes) Signature: void(ResponseSend&, const json&) The ResponseSend& parameter is automatically injected with request ID and response sink The json& parameter contains the raw JSON params from the request.

EXAMPLE: rpc.bindAsync("longTask", [](ResponseSend& send, const json& params) { // ACK already sent automatically // Do work... send.send(json::object().set("value", 42)); // Send result });

Definition at line 41 of file rpc.cpp.hpp.

                                                {
    fl::string key(name);
 
    detail::RpcEntry entry;
    entry.mTypeTag = detail::TypeTag<void(const json&)>::id();
    entry.mMode = mode;
    entry.mIsResponseAware = true;
    entry.mResponseAwareFn = fl::move(fn);
 
#if FL_PLATFORM_HAS_LARGE_MEMORY
    // Create schema generator for void(json) signature (params not decomposed).
    // Gated on Low-memory per FastLED #3081 / #3079 (rpc.discover unreachable).
    entry.mSchemaGenerator = fl::make_shared<detail::TypedSchemaGenerator<void(const json&)>>();
#endif
    entry.mDescription = "";
    entry.mTags = {};
 
    // Create a placeholder invoker (actual invocation handled in handle())
    struct PlaceholderInvoker : public detail::ErasedInvoker {
        fl::tuple<TypeConversionResult, json> invoke(const json&) FL_NO_EXCEPT override {
            // Should not be called - handle() will call mResponseAwareFn directly
            return fl::make_tuple(TypeConversionResult::success(), json(nullptr));
        }
    };
    entry.mInvoker = fl::make_shared<PlaceholderInvoker>();
 
    mRegistry[key] = fl::move(entry);
}

References fl::FL_NO_EXCEPT, fl::adl_barrier::invoke(), fl::adl_barrier::make_shared(), fl::adl_barrier::make_tuple(), fl::detail::RpcEntry::mDescription, fl::detail::RpcEntry::mInvoker, fl::detail::RpcEntry::mIsResponseAware, fl::detail::RpcEntry::mMode, fl::adl_barrier::move(), mRegistry, fl::detail::RpcEntry::mResponseAwareFn, fl::detail::RpcEntry::mSchemaGenerator, fl::detail::RpcEntry::mTags, fl::detail::RpcEntry::mTypeTag, and fl::TypeConversionResult::success().

Here is the call graph for this function: