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

Remove redundant comment

Browse Source
This commit is contained in:
Dave Syer
2017-07-17 13:54:37 +01:00
parent 182317dbe9
commit 947ce93d77
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java
View File

@@ -84,9 +84,6 @@ public class StreamListeningFunctionInvoker implements SmartInitializingSingleto
input.groupBy(this::select).flatMap(group -> group.key().process(group))); input.groupBy(this::select).flatMap(group -> group.key().process(group)));
} }
// TODO: the routing key could be added here, but really it should be added in
// Spring Cloud Stream
// (https://github.com/spring-cloud/spring-cloud-stream/issues/1010)
private Flux<Message<?>> function(String name, Flux<Message<?>> flux) { private Flux<Message<?>> function(String name, Flux<Message<?>> flux) {
Function<Object, Flux<?>> function = functionCatalog.lookupFunction(name); Function<Object, Flux<?>> function = functionCatalog.lookupFunction(name);
return flux.publish(values -> { return flux.publish(values -> {