code: public static <E> TopicProcessor<E> share(String name, int bufferSize) {
  		return TopicProcessor.<E>builder().share(true).name(name).bufferSize(bufferSize).build();
  	}
docs: 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