code: public final ConnectableFlux<T> publish(int prefetch) {
  		return onAssembly(new FluxPublish<>(this, prefetch, Queues
  				.get(prefetch)));
  	}
docs: 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}