diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
index 7b8f4ed13..4d54b9ac3 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
@@ -922,7 +922,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
 							.transform(mono -> {
 								mono =  Mono.from((Publisher) mono).map(v -> this.extractValueFromOriginalValueHolderIfNecessary(v));
 								((Consumer) this.target).accept(mono);
-								return Mono.ignoreElements((Flux) mono);
+								return Mono.ignoreElements((Mono) mono);
 							}).then();
 				}
 			}