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());
	}
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
Take a Publisher and prepare to consume it on multiple rails ( one per CPU core ) in a round - robin fashion .