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