From 98721d741cdf97245078ce73c92ce120b94c170e Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Fri, 9 Jul 2021 16:20:15 +0200
Subject: [PATCH] Put guard to make sure reactve supplier is not instrumented
 by sleuth

---
 .../cloud/function/context/catalog/FunctionAroundWrapper.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/FunctionAroundWrapper.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionAroundWrapper.java
index d33fab87d..87694f80d 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionAroundWrapper.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionAroundWrapper.java
@@ -40,7 +40,7 @@ public abstract class FunctionAroundWrapper implements BiFunction<Object, Functi
 		if (input instanceof Message) {
 			return this.doApply((Message<byte[]>) input, targetFunction);
 		}
-		else if (targetFunction.isSupplier()) {
+		else if (targetFunction.isSupplier() && !targetFunction.isOutputTypePublisher()) {
 			return this.doApply(null, targetFunction);
 		}
 		return targetFunction.apply(input);