From 67a4642b2d8de124bad6568402ba32bddbe27b45 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 27 Feb 2020 13:48:21 +0100 Subject: [PATCH] Polish/cleanup FunctionTypeUtils --- .../function/context/catalog/FunctionTypeUtils.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 ee70a00ba..8806ddca4 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 @@ -194,14 +194,14 @@ public final class FunctionTypeUtils { public static int getOutputCount(Type functionType) { assertSupportedTypes(functionType); - int inputCount = isConsumer(functionType) ? 0 : 1; + int outputCount = isConsumer(functionType) ? 0 : 1; if (functionType instanceof ParameterizedType && !isConsumer(functionType)) { - Type inputType = ((ParameterizedType) functionType).getActualTypeArguments()[isSupplier(functionType) ? 0 : 1]; - if (isMulti(inputType)) { - inputCount = ((ParameterizedType) inputType).getActualTypeArguments().length; + Type outputType = ((ParameterizedType) functionType).getActualTypeArguments()[isSupplier(functionType) ? 0 : 1]; + if (isMulti(outputType)) { + outputCount = ((ParameterizedType) outputType).getActualTypeArguments().length; } } - return inputCount; + return outputCount; } public static Type getInputType(Type functionType, int index) {