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)));
	}
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}
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 = >