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

updated Example

Browse Source
This commit is contained in:
markfisher
2016-10-14 20:46:02 -04:00
parent b0db0233be
commit 588e68f014
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/Example.java
View File

@@ -36,8 +36,8 @@ public class Example {
CompiledFunctionFactory<Function<Flux<String>,Flux<String>>> functionFactory = functionCompiler.compile("f", "f->f.map(s->s.toString().toUpperCase())");
Flux<String> output = functionFactory.getResult().apply(input);
ConsumerCompiler<Flux<String>> consumerCompiler = new ConsumerCompiler<>();
CompiledFunctionFactory<Consumer<Flux<String>>> consumerFactory = consumerCompiler.compile("c", "f->f.subscribe(System.out::println)");
consumerFactory.getResult().accept(output);
ConsumerCompiler<String> consumerCompiler = new ConsumerCompiler<>();
CompiledFunctionFactory<Consumer<String>> consumerFactory = consumerCompiler.compile("c", "System.out::println");
output.subscribe(consumerFactory.getResult());
}
}