reactor-core/src/main/java/reactor/core/publisher/ParallelFlux.java
public static <T> ParallelFlux<T> from(Publisher<? extends T> source) {
		return from(source,
				Runtime.getRuntime()
				       .availableProcessors(), Queues.SMALL_BUFFER_SIZE,
				Queues.small());
	}
public static <T> ParallelFlux<T> from(Publisher<? extends T> source) {
		return from(source,
				Runtime.getRuntime()
				       .availableProcessors(), Queues.SMALL_BUFFER_SIZE,
				Queues.small());
	}
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