public static <T>ParallelFlux<T> from(Publisher<? extends T> source,int parallelism){
  return from(source,parallelism,QueueSupplier.SMALL_BUFFER_SIZE,QueueSupplier.small());
}

public static < T > ParallelFlux < T > from ( Publisher < ? extends T > source , int parallelism ) { return from ( source , parallelism , QueueSupplier . SMALL_BUFFER_SIZE , QueueSupplier . small ( ) ) ; }
take a publisher and prepare to consume it on parallallism number of ' rails ' , possibly ordered and round - robin fashion .
