{
TestData
.getInputMessages()
- .forEach(word -> in.pipeInput(word.getUser(), word));
+ .forEach(kv -> in.pipeInput(kv.key, kv.value));
MultiValueMap<TestOutputWord, TestOutputWordCounter> receivedMessages = new LinkedMultiValueMap<>();
out
.forEach(record -> receivedMessages.add(record.key(), record.value()));
TestData.assertExpectedMessages(receivedMessages);
+
+ TestData.assertExpectedNumberOfMessagesForWord(receivedMessages);
+ TestData.assertExpectedLastMessagesForWord(receivedMessages);
}
@AfterEach