docs: public static <R> Publisher<R> parallelizePublisher(IntSet segments, Executor executor,
           IntFunction<Publisher<R>> publisherFunction) {
        return org.infinispan.persistence.internal.PersistenceUtil.parallelizePublisher(segments, Schedulers.from(executor),
              publisherFunction);
     }