From 32d18786c2aec11c8a5f052b36be6dd097c49bee Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Mon, 24 Oct 2022 17:25:18 +0200
Subject: [PATCH] polish

---
 .../observability/ObservationFunctionAroundWrapper.java      | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java
index 810aaa0ee..8f62c5fa8 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java
@@ -47,10 +47,7 @@ public class ObservationFunctionAroundWrapper extends FunctionAroundWrapper {
 
 	private Object nonReactorStream(Message<?> message,
 		SimpleFunctionRegistry.FunctionInvocationWrapper targetFunction) {
-		//if (targetFunction.isConsumer() || targetFunction.isFunction()) {
-			return functionProcessingObservation(targetFunction, message).observe(() -> targetFunction.apply(message));
-//		}
-//		return functionProcessingObservation(targetFunction, message).observe(targetFunction::get);
+		return functionProcessingObservation(targetFunction, message).observe(() -> targetFunction.apply(message));
 	}
 
 	private Observation functionProcessingObservation(SimpleFunctionRegistry.FunctionInvocationWrapper targetFunction, Message<?> message) {