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

Merge additional test to ensure propper type conversion

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-04-10 08:10:23 +02:00
parent 2c82cf91f8
commit 92468bcd53
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistryTests.java
View File

@@ -565,7 +565,7 @@ public class BeanFactoryAwareFunctionRegistryTests {
@Test @Test
public void testGH_608_C() { public void testGH_608_C() {
ApplicationContext context = new SpringApplicationBuilder(MessageFunctionConfiguration.class) ApplicationContext context = new SpringApplicationBuilder(SampleFunctionConfiguration.class)
.run("--logging.level.org.springframework.cloud.function=DEBUG", .run("--logging.level.org.springframework.cloud.function=DEBUG",
"--spring.main.lazy-initialization=true"); "--spring.main.lazy-initialization=true");
FunctionCatalog catalog = context.getBean(FunctionCatalog.class); FunctionCatalog catalog = context.getBean(FunctionCatalog.class);
@@ -836,11 +836,6 @@ public class BeanFactoryAwareFunctionRegistryTests {
} }
}; };
} }
@Bean
public Function<Flux<Message<Event<String, Person>>>, Flux<String>> echoGenericObjectFlux() {
return x -> x.map(eventMessage -> eventMessage.getPayload().getData().getName());
}
} }
@EnableAutoConfiguration @EnableAutoConfiguration
@@ -849,6 +844,11 @@ public class BeanFactoryAwareFunctionRegistryTests {
AtomicReference<Object> consumerInputRef = new AtomicReference<>(); AtomicReference<Object> consumerInputRef = new AtomicReference<>();
@Bean
public Function<Flux<Message<Event<String, Person>>>, Flux<String>> echoGenericObjectFlux() {
return x -> x.map(eventMessage -> eventMessage.getPayload().getData().getName());
}
@Bean @Bean
public Function<Person, Person> uppercasePerson() { public Function<Person, Person> uppercasePerson() {
return person -> { return person -> {