bindStreaming()

void fl::Rpc::bindStreaming	(	const char *	name,
		fl::StreamingRpcHandler	fn )

Bind a method that streams its JSON-RPC result directly to the transport.

The callback writes only the result payload; the RPC layer writes the JSON-RPC envelope and request id.

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

                                                                               {
#if FL_PLATFORM_HAS_LARGE_MEMORY
    fl::string key(name);
 
    detail::RpcEntry entry;
    entry.mTypeTag = detail::TypeTag<void(const json&)>::id();
    entry.mMode = RpcMode::SYNC;
    entry.mIsStreaming = true;
    entry.mStreamingFn = fl::move(fn);
 
    entry.mSchemaGenerator = fl::make_shared<detail::TypedSchemaGenerator<void(const json&)>>();
    entry.mDescription = "";
    entry.mTags = {};
 
    struct PlaceholderInvoker : public detail::ErasedInvoker {
        fl::tuple<TypeConversionResult, json> invoke(const json&) FL_NO_EXCEPT override {
            return fl::make_tuple(TypeConversionResult::success(), json(nullptr));
        }
    };
    entry.mInvoker = fl::make_shared<PlaceholderInvoker>();
 
    mRegistry[key] = fl::move(entry);
#else
    (void)name;
    (void)fn;
#endif
}

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::mMode, fl::adl_barrier::move(), mRegistry, fl::detail::RpcEntry::mSchemaGenerator, fl::detail::RpcEntry::mTags, fl::detail::RpcEntry::mTypeTag, fl::TypeConversionResult::success(), and fl::SYNC.

Here is the call graph for this function: