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

Update user guide azure content

Browse Source
This commit is contained in:
Dave Syer
2018-09-23 08:47:52 +01:00
parent 022f9213d8
commit debc9f8b30
3 changed files with 30 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-cloud-function-samples/function-sample-pojo/src/main/java/com/example/SampleApplication.java
View File

@@ -15,17 +15,18 @@
*/
package com.example;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.util.MultiValueMap;
import reactor.core.publisher.Flux;
import java.util.HashMap;
import java.util.Map;
import java.util.function.Function;
import java.util.function.Supplier;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.util.MultiValueMap;
import reactor.core.publisher.Flux;
@SpringBootApplication
public class SampleApplication {
@@ -41,18 +42,16 @@ public class SampleApplication {
@Bean
public Function<MultiValueMap<String, String>, Map<String, Integer>> sum() {
return multiValueMap -> {
Map<String, Integer> result = new HashMap<>();
multiValueMap.forEach((s, strings) -> result.put(s, strings.stream().mapToInt(Integer::parseInt).sum()));
multiValueMap.forEach((s, strings) -> result.put(s,
strings.stream().mapToInt(Integer::parseInt).sum()));
return result;
};
}
@Bean
public Supplier<Flux<Foo>> words() {
return () -> Flux.fromArray(new Foo[]{new Foo("foo"), new Foo("bar")}).log();
return () -> Flux.fromArray(new Foo[] { new Foo("foo"), new Foo("bar") }).log();
}
}