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) {