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

GH-473 Fix type discovery for generic parameters

Browse Source 
Resolves #473
This commit is contained in:
Oleg Zhurakousky
2020-03-30 10:56:00 +02:00
parent 9434a68bd2
commit 86d12f3a84
4 changed files with 32 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -128,9 +128,9 @@ public final class FunctionTypeUtils {
for (Type generic : generics) {
if (generic instanceof ParameterizedType) {
Class<?> rawClsss = (Class<?>) ((ParameterizedType) generic).getRawType();
if (rawClsss.isAssignableFrom(Function.class)
|| rawClsss.isAssignableFrom(Consumer.class)
|| rawClsss.isAssignableFrom(Supplier.class)) {
if (Function.class.isAssignableFrom(rawClsss)
|| Consumer.class.isAssignableFrom(rawClsss)
|| Supplier.class.isAssignableFrom(rawClsss)) {
return generic;
}
else {
@@ -145,6 +145,8 @@ public final class FunctionTypeUtils {
return null;
}
public static Type discoverFunctionTypeFromFunctionMethod(Method functionMethod) {
Assert.isTrue(
functionMethod.getName().equals("apply") ||

29
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/FunctionTypeUtilsTests.java
View File

@@ -19,7 +19,6 @@ package org.springframework.cloud.function.context.catalog;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Date;
import java.util.List;
import java.util.Map;
import java.util.function.Consumer;
@@ -132,6 +131,13 @@ public class FunctionTypeUtilsTests {
assertThat(type.getInputType()).isAssignableFrom(String.class);
}
@Test
public void foo() {
FunctionType type = FunctionType.of(FunctionTypeUtils.discoverFunctionTypeFromClass(ReactiveFunctionImpl.class));
assertThat(String.class).isAssignableFrom(type.getInputType());
assertThat(Integer.class).isAssignableFrom(type.getOutputType());
}
// @Test
// public void testInputTypeByIndex() throws Exception {
// Type functionType = getReturnType("function");
@@ -208,19 +214,19 @@ public class FunctionTypeUtilsTests {
//============
private interface MessageFunction<T> extends Function<Message<String>, Message<String>> {
private interface MessageFunction extends Function<Message<String>, Message<String>> {
}
private interface MyMessageFunction extends MessageFunction<Date> {
private interface MyMessageFunction extends MessageFunction {
}
private interface MessageConsumer<T> extends Consumer<Message<String>> {
private interface MessageConsumer extends Consumer<Message<String>> {
}
private interface MyMessageConsumer extends MessageConsumer<Date> {
private interface MyMessageConsumer extends MessageConsumer {
}
@@ -229,4 +235,17 @@ public class FunctionTypeUtilsTests {
public void accept(Flux<Message<String>> messageFlux) {
}
}
public interface ReactiveFunction<S, T> extends Function<Flux<S>, Flux<T>> {
}
public static class ReactiveFunctionImpl implements ReactiveFunction<String, Integer> {
@Override
public Flux<Integer> apply(Flux<String> inFlux) {
return inFlux.map(v -> Integer.parseInt(v));
}
}
}

3
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/source/ExporterProperties.java
View File

@@ -20,12 +20,13 @@ import java.util.LinkedHashMap;
import java.util.Map;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.function.context.FunctionProperties;
/**
* @author Dave Syer
*
*/
@ConfigurationProperties("spring.cloud.function.web.export")
@ConfigurationProperties(prefix = FunctionProperties.PREFIX + ".web.export")
public class ExporterProperties {
/**

2
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/source/SupplierExporter.java
View File

@@ -175,7 +175,7 @@ public class SupplierExporter implements SmartLifecycle {
body = message.getPayload();
}
Mono<ClientResponse> result = this.client.post().uri(uri)
.headers(headers -> headers(headers, destination, value)).syncBody(body)
.headers(headers -> headers(headers, destination, value)).bodyValue(body)
.exchange();
if (this.debug) {
result = result.log();