query: 1.0.6 - Refactored `TestData.assertExpectedState()`

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / query / QueryApplicationIT.java

diff --git a/src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java
index 4e44cda..914aeaf 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java
@@ -82,7 +82,7 @@ public class QueryApplicationIT
                await("Expected state")
                                .atMost(Duration.ofSeconds(5))
                                .catchUncaughtExceptions()
-                               .untilAsserted(() -> TestData.assertExpectedState(streamProcessor.getStore()));
+                               .untilAsserted(() -> TestData.assertExpectedState(user -> streamProcessor.getStore().get(user)));
        }
 
        @TestConfiguration