From 2438baff109090e5a01ed186dbee47f0459766df Mon Sep 17 00:00:00 2001 From: Dave Syer Date: Fri, 10 Nov 2017 13:13:34 +0000 Subject: [PATCH] Add TODO comment --- .../cloud/function/stream/StreamListeningFunctionInvoker.java | 1 + 1 file changed, 1 insertion(+) 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); } }