code: public final <R> Flux<R> publish(Function<? super Flux<T>, ? extends Publisher<?
  			extends R>> transform) {
  		return publish(transform, Queues.SMALL_BUFFER_SIZE);
  	}
docs: Shares a sequence for the duration of a function that may transform it and
  consume it as many times as necessary without causing multiple subscriptions
  to the upstream.
  
  @param transform the transformation function
  @param <R> the output value type
  
  @return a new {@link Flux}