@Test
public void getAndConsumeShouldPropagateIOException() throws IOException {

  final IOException cause = new IOException("foo");
  doReturn(Stream.of(entity1, entity2).iterator()).when(rw).get(key1, key2);
  exception.expect(is(cause));
  sut.get(List.of(key1, key2), entity -> { throw cause; });
}