@Test public void testErrorPropagated() {

  Error error = new Error();
  UncheckedExecutionException exception = assertThrows(
      UncheckedExecutionException.class,
      () -> parallelize(Stream.of(() -> raise(error))));
  assertThat(exception.getCause()).isSameAs(error);
}