reactor-core/src/main/java/reactor/core/publisher/TopicProcessor.java
public static <E> TopicProcessor<E> create(String name, int bufferSize) {
		return TopicProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
public static <E> TopicProcessor<E> create(String name, int bufferSize) {
		return TopicProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
Create a new TopicProcessor using the provided backlog size, with a blockingWait Strategy
and auto-cancellation. <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 the fresh TopicProcessor instance