X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryApplicationIT.java;h=914aeaf35f0bdf4e419a7b5e9877c61b76fa1a83;hb=cfd58858b9861e8d0e4c1d30896505a50f63255b;hp=4e44cdaa2f4d7524ad6dd1eea57a157dc9bde1e3;hpb=2b22a006cc57203406c8589687a6c729ebdbf40c;p=demos%2Fkafka%2Fwordcount

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
--- 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