docs: public static <T> QueueBasedSubscriber<T> subscriber(final QueueFactory<T> factory, final Counter counter, final int maxConcurrency) {
  
          return new QueueBasedSubscriber<>(
                  factory, counter, maxConcurrency);
      }