reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> share() {
		return onAssembly(new FluxRefCount<>(
				new FluxPublish<>(this, Queues.SMALL_BUFFER_SIZE, Queues.small()), 1)
		);
	}
public final Flux<T> share() {
		return onAssembly(new FluxRefCount<>(
				new FluxPublish<>(this, Queues.SMALL_BUFFER_SIZE, Queues.small()), 1)
		);
	}
public final Flux < T > share ( ) { return onAssembly ( new FluxRefCount <> ( new FluxPublish <> ( this , Queues . SMALL_BUFFER_SIZE , Queues . small ( ) ) , 1 ) ) ; }
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.
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 () } .