public static < T > QueueBasedSubscriber < T > subscriber ( final Counter counter , final int maxConcurrency ) { return new QueueBasedSubscriber <> ( counter , maxConcurrency ) ; }
Create a QueueBasedSubscriber backed by a JDK LinkedBlockingQueue