reactor-core/src/main/java/reactor/core/publisher/TopicProcessor.java
public static <E> TopicProcessor<E> share(String name, int bufferSize) {
		return TopicProcessor.<E>builder().share(true).name(name).bufferSize(bufferSize).build();
	}
public static <E> TopicProcessor<E> share(String name, int bufferSize) {
		return TopicProcessor.<E>builder().share(true).name(name).bufferSize(bufferSize).build();
	}
Create a new shared TopicProcessor using the passed backlog size, with a blockingWait
Strategy and auto-cancellation.
<p>
A Shared Processor authorizes concurrent onNext calls and is suited for multi-threaded
publisher that will fan-in data.
<p>
A new Cached ThreadExecutorPool will be implicitly created and will use the passed
name to qualify the created threads.
@param name Use a new Cached ExecutorService and assign this name to the created
threads
@param bufferSize A Backlog Size to mitigate slow subscribers
@param <E> Type of processed signals
@return a fresh processor