import java.util.Map;
import java.util.Properties;
+import java.util.stream.Stream;
import static de.juplo.kafka.wordcount.counter.TestData.convertToMap;
import static de.juplo.kafka.wordcount.counter.TestData.parseHeader;
@Test
public void test()
{
- TestData.injectInputMessages((key, value) -> in.pipeInput(key, value));
+ Stream
+ .of(TestData.INPUT_MESSAGES)
+ .forEach(word -> in.pipeInput(word.getUser(), word));
MultiValueMap<Word, WordCounter> receivedMessages = new LinkedMultiValueMap<>();
out