diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtils.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtils.java index d7d8863b3..58581746c 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtils.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtils.java @@ -171,8 +171,6 @@ public final class FunctionTypeUtils { @SuppressWarnings("unchecked") public static Type discoverFunctionTypeFromClass(Class functionalClass) { - Assert.isTrue(isFunctional(functionalClass), "Type must be one of Supplier, Function or Consumer"); - if (Function.class.isAssignableFrom(functionalClass)) { for (Type superInterface : functionalClass.getGenericInterfaces()) { if (superInterface != null && !superInterface.equals(Object.class)) { diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java index 3b6209447..1076ab738 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java @@ -98,9 +98,6 @@ public class KotlinLambdaToFunctionAutoConfiguration { if (ObjectUtils.isEmpty(input)) { return this.invoke(); } - else if (ObjectUtils.isArray(input)) { - return null; - } else { return this.invoke(input); }