@Test public void testExceptionPropagated() {

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