code: public final Flux<T> share() {
  		return onAssembly(new FluxRefCount<>(
  				new FluxPublish<>(this, Queues.SMALL_BUFFER_SIZE, Queues.small()), 1)
  		);
  	}
docs: Returns a new {@link Flux} that multicasts (shares) the original {@link Flux}.
  As long as there is at least one {@link Subscriber} this {@link Flux} will be subscribed and
  emitting data.
  When all subscribers have cancelled it will cancel the source
  {@link Flux}.
  <p>This is an alias for {@link #publish()}.{@link ConnectableFlux#refCount()}.
  
  @return a {@link Flux} that upon first subscribe causes the source {@link Flux}
  to subscribe once, late subscribers might therefore miss items.