<BUG>if (parallelism <= 0) {throw new IllegalArgumentException("parallelism > 0 required but it was " + parallelism);}if (prefetch <= 0) {throw new IllegalArgumentException("prefetch > 0 required but it was " + prefetch);}</BUG><CONTEXT>}public static <T> ParallelFlux<T> from(Publisher<? extends T> source,int parallelism,int prefetch,Supplier<Queue<T>> queueSupplier) {<extra_id_0>Objects.requireNonNull(queueSupplier, "queueSupplier");</CONTEXT>
int parallelism) {return from(source,parallelism, QueueSupplier.SMALL_BUFFER_SIZE,QueueSupplier.small());