@Test
public void getAndConsume() throws IOException {

  when(rw.get(key1, key2)).thenReturn(Stream.of(entity1, entity2).iterator());
  sut.get(List.of(key1, key2), entityConsumer);
  verify(rw).get(key1, key2);
  verify(entityConsumer).accept(entity1);
  verify(entityConsumer).accept(entity2);
}