WorkQueueProcessor extends EventLoopProcessor<E> { public static <E> WorkQueueProcessor<E> share(String name, int bufferSize) { return WorkQueueProcessor.<E>builder().share(true).name(name).bufferSize(bufferSize).build(); } @SuppressWarnings("unchecked")  WorkQueueProcessor(
			@Nullable ThreadFactory threadFactory,
			@Nullable ExecutorService executor,
			ExecutorService requestTaskExecutor,
			int bufferSize, WaitStrategy waitStrategy, boolean share,
	                                boolean autoCancel); final static Builder<T> builder(); static WorkQueueProcessor<E> create(); static WorkQueueProcessor<E> create(String name, int bufferSize); static WorkQueueProcessor<E> share(String name, int bufferSize); @Override void subscribe(final CoreSubscriber<? super E> actual); @Override Flux<E> drain(); @Override long getPending(); @Override void run();  }
@Test public void shareOverrideNameBufferSize() { String name = "nameOverride"; int bufferSize = 1024; WorkQueueProcessor<Integer> processor = WorkQueueProcessor.share(name, bufferSize); assertProcessor(processor, true, name, bufferSize, null, null, null, null); }