X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FTestData.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FTestData.java;h=54e62878eec602a682a53dce9ba60315b94070d9;hb=e6198710fe679bc7463d1b17c9d9dc311062ef31;hp=7446db6b8a11b32fcde42e8e417a0fe9bb544917;hpb=8d0426539d69616900f4d6ef19e52d50b497f57f;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/TestData.java b/src/test/java/de/juplo/kafka/wordcount/counter/TestData.java
index 7446db6..54e6287 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/TestData.java
@@ -1,5 +1,6 @@
 package de.juplo.kafka.wordcount.counter;
 
+import de.juplo.kafka.wordcount.splitter.TestInputUser;
 import de.juplo.kafka.wordcount.splitter.TestInputWord;
 import de.juplo.kafka.wordcount.top10.TestOutputWord;
 import de.juplo.kafka.wordcount.top10.TestOutputWordCounter;
@@ -30,44 +31,44 @@ class TestData
 	static final TestOutputWord KLAUS_MÜSCH = TestOutputWord.of(KLAUS, WORD_MÜSCH);
 	static final TestOutputWord KLAUS_S = TestOutputWord.of(KLAUS, WORD_S);
 
-	private static final KeyValue<String, TestInputWord>[] INPUT_MESSAGES = new KeyValue[]
+	private static final KeyValue<TestInputUser, TestInputWord>[] INPUT_MESSAGES = new KeyValue[]
 	{
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_HALLO)),
 			new KeyValue<>(
-					KLAUS,
+					TestInputUser.of(KLAUS),
 					TestInputWord.of(KLAUS, WORD_MÜSCH)),
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_WELT)),
 			new KeyValue<>(
-					KLAUS,
+					TestInputUser.of(KLAUS),
 					TestInputWord.of(KLAUS, WORD_MÜSCH)),
 			new KeyValue<>(
-					KLAUS,
+					TestInputUser.of(KLAUS),
 					TestInputWord.of(KLAUS, WORD_S)),
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_BOÄH)),
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_WELT)),
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_BOÄH)),
 			new KeyValue<>(
-					KLAUS,
+					TestInputUser.of(KLAUS),
 					TestInputWord.of(KLAUS, WORD_S)),
 			new KeyValue<>(
-					PETER,
+					TestInputUser.of(PETER),
 					TestInputWord.of(PETER, WORD_BOÄH)),
 			new KeyValue<>(
-					KLAUS,
+					TestInputUser.of(KLAUS),
 					TestInputWord.of(KLAUS, WORD_S)),
 	};
 
-	static Stream<KeyValue<String, TestInputWord>> getInputMessages()
+	static Stream<KeyValue<TestInputUser, TestInputWord>> getInputMessages()
 	{
 		return Stream.of(TestData.INPUT_MESSAGES);
 	}