.forEach(kv -> in.pipeInput(kv.key, kv.value));
MultiValueMap<TestUser, TestRanking> receivedMessages = new LinkedMultiValueMap<>();
.forEach(kv -> in.pipeInput(kv.key, kv.value));
MultiValueMap<TestUser, TestRanking> receivedMessages = new LinkedMultiValueMap<>();