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

gh-608 issue

Browse Source
This commit is contained in:
Taras Danylchuk
2021-04-09 12:37:35 -04:00
parent 8b9051dfeb
commit 185f16b3ce
1 changed files with 19 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -563,6 +563,20 @@ public class BeanFactoryAwareFunctionRegistryTests {
assertThat(productJson).isEqualTo(new String(result.getPayload()));
}
@Test
public void testGH_608_C() {
ApplicationContext context = new SpringApplicationBuilder(MessageFunctionConfiguration.class)
.run("--logging.level.org.springframework.cloud.function=DEBUG",
"--spring.main.lazy-initialization=true");
FunctionCatalog catalog = context.getBean(FunctionCatalog.class);
String productJson = "{\"key\":\"someKey\",\"data\": {\"name\":\"bike\"}}";
FunctionInvocationWrapper function = catalog.lookup("echoGenericObjectFlux", "application/json");
Message<byte[]> result = ((Flux<Message<byte[]>>) function.apply(productJson)).blockFirst();
assertThat(new String(result.getPayload())).isEqualTo("\"bike\"");
}
@Test
public void testGH_609() {
FunctionCatalog catalog = this.configureCatalog(SampleFunctionConfiguration.class);
@@ -833,6 +847,11 @@ public class BeanFactoryAwareFunctionRegistryTests {
public Function<Flux<Message<Product>>, Flux<Message<Product>>> echoFlux() {
return x -> x;
}
@Bean
public Function<Flux<Message<Event<String, Person>>>, Flux<String>> echoGenericObjectFlux() {
return x -> x.map(eventMessage -> eventMessage.getPayload().getData().getName());
}
}
@EnableAutoConfiguration