From 82e68d4221b0430fc5d9ddf90a91ce60ff93cd56 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 26 Oct 2021 15:25:59 +0200 Subject: [PATCH] Minor cleanup --- .../cloud/function/context/catalog/SimpleFunctionRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(); } }