diff --git a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java index 46df7e6ee..e36a4a193 100644 --- a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java +++ b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java @@ -169,6 +169,7 @@ public class StreamListeningFunctionInvoker implements SmartInitializingSingleto name = stash(matches.iterator().next()); } else { + // TODO: do we really want this? Or maybe warn that it is happening? return flux -> balance(matches, flux); } }