@Test
public void parallelizeSupplier() {

    assertEquals((long) Streams.parallelize(3, () -> 42L)
            .filter(r -> !r.hasError())
            .map(ResultWrapper::getResult)
            .reduce(0L, (a, b) -> a + b), 126L);
}