From 6b2bd03c093ed1b3e3b353c8b862b8fc8575611b Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 17 Jun 2024 21:53:34 +0200
Subject: [PATCH] popular: 1.1.0 - Formulated expectations for suppressed
 results

* Removed result-messages, that will be supressed
* Added additionally messages, that are necessary, to advance the
  stream-time and close the window.
---
 pom.xml                                       |  2 +-
 .../kafka/wordcount/popular/TestData.java     | 38 ++++++++++---------
 2 files changed, 21 insertions(+), 19 deletions(-)

diff --git a/pom.xml b/pom.xml
index a9aae74..a9ba9e1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>de.juplo.kafka.wordcount</groupId>
 	<artifactId>popular</artifactId>
-	<version>1.0.0</version>
+	<version>1.1.0</version>
 	<name>Wordcount-Popular-Words</name>
 	<description>Query stream-processor that gives access to the most popular words</description>
 	<properties>
diff --git a/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java b/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java
index 372e0c0..fa6a258 100644
--- a/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java
@@ -102,6 +102,26 @@ class TestData
 					instantOfSecond(20),
 					InputUser.of(KLAUS),
 					InputWord.of(KLAUS, WORD_S)),
+			TestMessage.of(
+					instantOfSecond((int)WINDOW_SIZE.toSeconds()),
+					InputUser.of(PETER),
+					InputWord.of(PETER, WORD_HALLO)),
+			TestMessage.of(
+					instantOfSecond((int)WINDOW_SIZE.toSeconds()),
+					InputUser.of(KLAUS),
+					InputWord.of(KLAUS, WORD_MÜSCH)),
+			TestMessage.of(
+					instantOfSecond((int)WINDOW_SIZE.toSeconds()),
+					InputUser.of(PETER),
+					InputWord.of(PETER, WORD_WELT)),
+			TestMessage.of(
+					instantOfSecond((int)WINDOW_SIZE.toSeconds()),
+					InputUser.of(KLAUS),
+					InputWord.of(KLAUS, WORD_S)),
+			TestMessage.of(
+					instantOfSecond((int)WINDOW_SIZE.toSeconds()),
+					InputUser.of(PETER),
+					InputWord.of(PETER, WORD_BOÄH)),
 	};
 
 	private static Instant instantOfSecond(int second)
@@ -223,30 +243,12 @@ class TestData
 			KeyValue.pair(
 					WINDOWED_WORD_HALLO,
 					OutputWordCounter.of(WORD_HALLO,1)),
-			KeyValue.pair(
-					WINDOWED_WORD_MÜSCH,
-					OutputWordCounter.of(WORD_MÜSCH,1)),
-			KeyValue.pair(
-					WINDOWED_WORD_WELT,
-					OutputWordCounter.of(WORD_WELT,1)),
 			KeyValue.pair(
 					WINDOWED_WORD_MÜSCH,
 					OutputWordCounter.of(WORD_MÜSCH,2)),
-			KeyValue.pair(
-					WINDOWED_WORD_S,
-					OutputWordCounter.of(WORD_S,1)),
-			KeyValue.pair(
-					WINDOWED_WORD_BOÄH,
-					OutputWordCounter.of(WORD_BOÄH,1)),
 			KeyValue.pair(
 					WINDOWED_WORD_WELT,
 					OutputWordCounter.of(WORD_WELT,2)),
-			KeyValue.pair(
-					WINDOWED_WORD_BOÄH,
-					OutputWordCounter.of(WORD_BOÄH,2)),
-			KeyValue.pair(
-					WINDOWED_WORD_S,
-					OutputWordCounter.of(WORD_S,2)),
 			KeyValue.pair(
 					WINDOWED_WORD_BOÄH,
 					OutputWordCounter.of(WORD_BOÄH,3)),
-- 
2.20.1