code: public static <T> QueueBasedSubscriber<T> subscriber(final Queue<T> q, final Counter counter, final int maxConcurrency) {
          return new QueueBasedSubscriber<>(
                  q, counter, maxConcurrency);
      }
docs: Create a QueueBasedSubscriber, backed by the provided Queue
  
  @param q Queue backing the reactiveSubscriber
  @param counter Counter for tracking connections to the queue and data volumes
  @param maxConcurrency Maximum number of subscriptions
  @return QueueBasedSubscriber