public ScheduledTaskConcurrency()

in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/AbstractConcurrencyLoadBalancer.java [151:160]

• 10 lines of code
• 1 McCabe index (conditional complexity)

        public ScheduledTaskConcurrency(TaskConcurrency<T> delegate, ScheduledCounter.Builder builder) {
            super(delegate);
            this.timeout = builder.getMaxDelay();
            this.scheduledCounter = builder.of(new Consumer<Long>() {
                @Override
                public void accept(Long n) {
                    delegate.complete(n.intValue(), timeout.multipliedBy(n.intValue()));
                }
            });
        }