reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final ConnectableFlux<T> publish(int prefetch) {
		return onAssembly(new FluxPublish<>(this, prefetch, Queues
				.get(prefetch)));
	}
public final ConnectableFlux<T> publish(int prefetch) {
		return onAssembly(new FluxPublish<>(this, prefetch, Queues
				.get(prefetch)));
	}
Prepare a {@link ConnectableFlux} which shares this {@link Flux} sequence and
dispatches values to subscribers in a backpressure-aware manner. This will
effectively turn any type of sequence into a hot sequence.
<p>
Backpressure will be coordinated on {@link Subscription#request} and if any
{@link Subscriber} is missing demand (requested = 0), multicast will pause
pushing/pulling.
<p>
<img class="marble" src="doc-files/marbles/publish.svg" alt="">

@param prefetch bounded requested demand

@return a new {@link ConnectableFlux}