code: public static <T> ParallelFlux<T> from(Publisher<? extends T> source) {
  		return from(source,
  				Runtime.getRuntime()
  				       .availableProcessors(), Queues.SMALL_BUFFER_SIZE,
  				Queues.small());
  	}
docs: Take a Publisher and prepare to consume it on multiple 'rails' (one per CPU core)
  in a round-robin fashion.
  
  @param <T> the value type
  @param source the source Publisher
  
  @return the {@link ParallelFlux} instance