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

Minor enhancements and polishing to accomodate s-c-stream requirements for multi-in/out bindings

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-09-17 17:50:35 +02:00
parent b65dff8b26
commit 9011615c30
3 changed files with 35 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java
View File

@@ -451,6 +451,10 @@ public class BeanFactoryAwareFunctionRegistry
return this.doApply(input, false);
}
public Type getFunctionType() {
return this.functionType;
}
public boolean isConsumer() {
return FunctionTypeUtils.isConsumer(this.functionType);
}

39
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtils.java
View File

@@ -16,6 +16,7 @@
package org.springframework.cloud.function.context.catalog;
import java.lang.reflect.GenericArrayType;
import java.lang.reflect.Method;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
@@ -78,7 +79,6 @@ public final class FunctionTypeUtils {
* @return functional method
*/
public static Method discoverFunctionalMethod(Class<?> pojoFunctionClass) {
if (Supplier.class.isAssignableFrom(pojoFunctionClass)) {
return Stream.of(ReflectionUtils.getDeclaredMethods(pojoFunctionClass)).filter(m -> m.getName().equals("get")).findFirst().get();
}
@@ -182,7 +182,7 @@ public final class FunctionTypeUtils {
inputType = ((ParameterizedType) functionType).getActualTypeArguments()[0];
inputType = isMulti(inputType)
? ((ParameterizedType) inputType).getActualTypeArguments()[index]
: ((ParameterizedType) functionType).getActualTypeArguments()[index];
: inputType;
}
return inputType;
@@ -190,15 +190,15 @@ public final class FunctionTypeUtils {
public static Type getOutputType(Type functionType, int index) {
assertSupportedTypes(functionType);
Type inputType = isConsumer(functionType) ? null : Object.class;
Type outputType = isConsumer(functionType) ? null : Object.class;
if ((isFunction(functionType) || isSupplier(functionType)) && functionType instanceof ParameterizedType) {
inputType = ((ParameterizedType) functionType).getActualTypeArguments()[isFunction(functionType) ? 1 : 0];
inputType = isMulti(inputType)
? ((ParameterizedType) inputType).getActualTypeArguments()[index]
: ((ParameterizedType) functionType).getActualTypeArguments()[index];
outputType = ((ParameterizedType) functionType).getActualTypeArguments()[isFunction(functionType) ? 1 : 0];
outputType = isMulti(outputType)
? ((ParameterizedType) outputType).getActualTypeArguments()[index]
: outputType;
}
return inputType;
return outputType;
}
public static Type getImmediateGenericType(Type type, int index) {
@@ -232,8 +232,31 @@ public final class FunctionTypeUtils {
return type.getTypeName().startsWith("org.springframework.messaging.Message");
}
/**
* Determines if input argument to a Function is an array.
* @param functionType the function type
* @return true if input type is an array, otherwise false
*/
public static boolean isInputArray(Type functionType) {
Type inputType = FunctionTypeUtils.getInputType(functionType, 0);
return inputType instanceof GenericArrayType || inputType instanceof Class && ((Class<?>) inputType).isArray();
}
/**
* Determines if input argument to a Function is an array.
* @param functionType the function type
* @return true if input type is an array, otherwise false
*/
public static boolean isOutputArray(Type functionType) {
Type outputType = FunctionTypeUtils.getOutputType(functionType, 0);
return outputType instanceof GenericArrayType || outputType instanceof Class && ((Class<?>) outputType).isArray();
}
/**
* Evaluates if provided type is an assignable to {@link Publisher}.
* @param type type to evaluate
* @return true is provided type is an assignable to {@link Publisher}
*/
public static boolean isReactive(Type type) {
Class<?> rawType = type instanceof ParameterizedType
? (Class<?>) ((ParameterizedType) type).getRawType() : (type instanceof Class<?> ? (Class<?>) type : Object.class);

3
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistryMultiInOutTests.java
View File

@@ -379,9 +379,6 @@ public class BeanFactoryAwareFunctionRegistryMultiInOutTests {
return new Flux[] { repeated, sum };
};
}
}