+ static Stream<KeyValue<String, TestWord>> expectedMessages = Stream.of(
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "Hallo")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "Welt")),
+ KeyValue.pair(
+ "klaus",
+ new TestWord("klaus", "Müsch")),
+ KeyValue.pair(
+ "klaus",
+ new TestWord("klaus", "gäb")),
+ KeyValue.pair(
+ "klaus",
+ new TestWord("klaus", "s")),
+ KeyValue.pair(
+ "klaus",
+ new TestWord("klaus", "auch")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "Boäh")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "echt")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "ß")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "mal")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "nä")),
+ KeyValue.pair(
+ "peter",
+ new TestWord("peter", "Nümmäh")));
+