    @Test
    public void parallelizeSupplier() {

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