* Assume that the Function returned by FunctionCatalog is already wrapped as Function<Flux<?>,Flux<?>>