SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

polish

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-10-24 17:25:18 +02:00
parent 09b1317620
commit 32d18786c2
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java
View File

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