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

GH-608 Additional fix based on provided failed test

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-04-10 07:56:08 +02:00
parent 185f16b3ce
commit a0457fc540
1 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -822,14 +822,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
boolean convertWithHint = false;
Type hint = FunctionTypeUtils.getGenericType(type);
convertWithHint = this.useConversionHint(type, rawType);
// if (FunctionTypeUtils.isTypeCollection(type)) {
// convertWithHint = true;
// }
// else if (!FunctionTypeUtils.isPublisher(type) && !rawType.equals(type) && !FunctionTypeUtils.isMessage(type)) {
// convertWithHint = true;
// }
convertWithHint = this.useConversionHint(type, rawType, hint);
convertedValue = convertWithHint
? this.fromMessage((Message<?>) value, (Class<?>) rawType, hint)
@@ -867,8 +860,11 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
return convertedValue;
}
private boolean useConversionHint(Type type, Type rawType) {
if (FunctionTypeUtils.isTypeCollection(type)) {
private boolean useConversionHint(Type type, Type rawType, Type hint) {
if (hint instanceof ParameterizedType) {
return true;
}
else if (FunctionTypeUtils.isTypeCollection(type)) {
return true;
}
else if (!FunctionTypeUtils.isPublisher(type) && !rawType.equals(type) && !FunctionTypeUtils.isMessage(type)) {