- static void assertExpectedMessages(MultiValueMap<String, TestWord> receivedMessages)
- {
- MultiValueMap<String, TestWord> expected = new LinkedMultiValueMap<>();
- expectedMessages.forEach(keyValue -> expected.add(keyValue.key, keyValue.value));
- await("Received expected messages")
- .atMost(Duration.ofSeconds(5))
- .untilAsserted(() -> expected.forEach((user, word) ->
- assertThat(receivedMessages.get(user)).containsExactlyElementsOf(word)));
- }
-
- 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")));
-
-